Skip to content

Commit 69c38df

Browse files
committed
1 parent eaa9517 commit 69c38df

2 files changed

Lines changed: 25 additions & 2 deletions

File tree

polycode/client.go

Lines changed: 14 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -224,6 +224,12 @@ type SignalWaitResponse struct {
224224
Error Error `json:"error"`
225225
}
226226

227+
type GetMetaDataRequest struct {
228+
Group string `json:"group"`
229+
Type string `json:"type"`
230+
Key string `json:"key"`
231+
}
232+
227233
type IncrementCounterRequest struct {
228234
Group string `json:"group"`
229235
Name string `json:"name"`
@@ -426,7 +432,7 @@ func (sc *ServiceClient) WaitForSignal(sessionId string, req SignalWaitRequest)
426432
}
427433

428434
func (sc *ServiceClient) EmitRealtimeEvent(sessionId string, req RealtimeEventEmitRequest) error {
429-
return executeApiWithoutResponse(sc.httpClient, sc.baseURL, sessionId, "v1/realtime/event/emit", req)
435+
return executeApiWithoutResponse(sc.httpClient, sc.baseURL, sessionId, "v1/context/realtime/event/emit", req)
430436
}
431437

432438
func (sc *ServiceClient) AcquireLock(sessionId string, req AcquireLockRequest) error {
@@ -439,7 +445,13 @@ func (sc *ServiceClient) ReleaseLock(sessionId string, req ReleaseLockRequest) e
439445

440446
func (sc *ServiceClient) IncrementCounter(sessionId string, req IncrementCounterRequest) (IncrementCounterResponse, error) {
441447
var res IncrementCounterResponse
442-
err := executeApiWithResponse(sc.httpClient, sc.baseURL, sessionId, "v1/utils/counter/increment", req, &res)
448+
err := executeApiWithResponse(sc.httpClient, sc.baseURL, sessionId, "v1/elevated/context/counter/increment", req, &res)
449+
return res, err
450+
}
451+
452+
func (sc *ServiceClient) GetMeta(sessionId string, req GetMetaDataRequest) (map[string]interface{}, error) {
453+
var res map[string]interface{}
454+
err := executeApiWithResponse(sc.httpClient, sc.baseURL, sessionId, "v1/elevated/context/meta/get", req, &res)
443455
return res, err
444456
}
445457

polycode/context.go

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,7 @@ type ApiContext interface {
4747

4848
type RawContext interface {
4949
BaseContext
50+
GetMeta(group string, typeName string, key string) (map[string]interface{}, error)
5051
Counter(group string, name string, ttl int64) Counter
5152
}
5253

@@ -187,6 +188,16 @@ func (s ContextImpl) Lock(key string) Lock {
187188
}
188189
}
189190

191+
func (s ContextImpl) GetMeta(group string, typeName string, key string) (map[string]interface{}, error) {
192+
req := GetMetaDataRequest{
193+
Group: group,
194+
Type: typeName,
195+
Key: key,
196+
}
197+
198+
return s.serviceClient.GetMeta(s.sessionId, req)
199+
}
200+
190201
func (s ContextImpl) Counter(group string, name string, ttl int64) Counter {
191202
return Counter{
192203
client: s.serviceClient,

0 commit comments

Comments
 (0)