Documentation ¶
Index ¶
- func CreateCiosWsConn(isDebug bool, url, authorization string) (connection *websocket.Conn, err error)
- func CreateCiosWsMessagingURL(httpUrl, channelID, mode string, packerFormat *string) string
- func MakeGetChannelsOpts() cios.ApiGetChannelsRequest
- func MakeGetDataStoreChannelsOpts() cios.ApiGetDataStoreChannelsRequest
- func MakeGetObjectsOpts() cios.ApiGetDataStoreObjectsRequest
- func MakeGetStreamOpts() sdkmodel.ApiGetStreamRequest
- type CiosMessaging
- func (self *CiosMessaging) Close() (err error)
- func (self *CiosMessaging) MapReceived(stct interface{}) error
- func (self *CiosMessaging) OnClose(arg func())
- func (self *CiosMessaging) OnReceive(arg func([]byte) (bool, error)) error
- func (self *CiosMessaging) Publish(message interface{}) error
- func (self *CiosMessaging) Receive() (body []byte, err error)
- func (self *CiosMessaging) ReceiveStr() (string, error)
- func (self *CiosMessaging) Send(message []byte) (err error)
- func (self *CiosMessaging) SendAny(message interface{}) error
- func (self *CiosMessaging) SendJson(message interface{}) error
- func (self *CiosMessaging) SendStr(message string) error
- func (self *CiosMessaging) SetReadTimeout(t time.Duration) *CiosMessaging
- func (self *CiosMessaging) SetWriteTimeout(t time.Duration) *CiosMessaging
- func (self *CiosMessaging) Start(ctx ciosctx.RequestCtx) (err error)
- type CiosPubSub
- func (self *CiosPubSub) ConnectWebSocket(channelID string, done chan bool, params ConnectWebSocketOptions) (err error)deprecated
- func (self *CiosPubSub) CreateCIOSWebsocketConnection(url string, authorization string) (connection *websocket.Conn, err error)deprecated
- func (self *CiosPubSub) CreateChannel(ctx ciosctx.RequestCtx, body cios.ChannelProposal) (cios.Channel, *_nethttp.Response, error)
- func (self *CiosPubSub) CreateMessagingURL(channelID string, mode string, packerFormat *string) stringdeprecated
- func (self *CiosPubSub) DeleteChannel(ctx ciosctx.RequestCtx, channelID string) (*_nethttp.Response, error)
- func (self *CiosPubSub) DeleteDataByChannel(ctx ciosctx.RequestCtx, channelID string) (*_nethttp.Response, error)
- func (self *CiosPubSub) DeleteObject(ctx ciosctx.RequestCtx, channelID string, objectID string) (*_nethttp.Response, error)
- func (self *CiosPubSub) GetChannel(ctx ciosctx.RequestCtx, channelID string, isDev *bool, lang *string) (cios.Channel, *_nethttp.Response, error)
- func (self *CiosPubSub) GetChannelFirst(ctx ciosctx.RequestCtx, params cios.ApiGetChannelsRequest) (cios.Channel, *_nethttp.Response, error)
- func (self *CiosPubSub) GetChannels(ctx ciosctx.RequestCtx, params cios.ApiGetChannelsRequest) (response cios.MultipleChannel, httpResponse *_nethttp.Response, err error)
- func (self *CiosPubSub) GetChannelsAll(ctx ciosctx.RequestCtx, params cios.ApiGetChannelsRequest) ([]cios.Channel, *_nethttp.Response, error)
- func (self *CiosPubSub) GetChannelsMapByID(ctx ciosctx.RequestCtx, params cios.ApiGetChannelsRequest) (map[string]cios.Channel, *_nethttp.Response, error)
- func (self *CiosPubSub) GetChannelsMapByResourceOwnerID(ctx ciosctx.RequestCtx, params cios.ApiGetChannelsRequest) (map[string][]cios.Channel, *_nethttp.Response, error)
- func (self *CiosPubSub) GetChannelsUnlimited(ctx ciosctx.RequestCtx, params cios.ApiGetChannelsRequest) ([]cios.Channel, *_nethttp.Response, error)
- func (self *CiosPubSub) GetDataStoreChannel(ctx ciosctx.RequestCtx, channelID string) (cios.DataStoreChannel, *_nethttp.Response, error)
- func (self *CiosPubSub) GetDataStoreChannels(ctx ciosctx.RequestCtx, params cios.ApiGetDataStoreChannelsRequest) (response cios.MultipleDataStoreChannel, httpResponse *_nethttp.Response, ...)
- func (self *CiosPubSub) GetJsonStreamUnlimited(ctx ciosctx.RequestCtx, channelID string, params sdkmodel.ApiGetStreamRequest) (result []cios.PackerFormatJson, err error)
- func (self *CiosPubSub) GetMultiObjectLatest(ctx ciosctx.RequestCtx, channelIDs []string) (cios.MultipleDataStoreDataLatest, *_nethttp.Response, error)
- func (self *CiosPubSub) GetMultiObjectLatestByChannels(ctx ciosctx.RequestCtx, channels []cios.Channel) (cios.MultipleDataStoreDataLatest, *_nethttp.Response, error)
- func (self *CiosPubSub) GetObject(ctx ciosctx.RequestCtx, channelID string, objectID string, ...) (interface{}, *_nethttp.Response, error)
- func (self *CiosPubSub) GetObjectLatest(ctx ciosctx.RequestCtx, channelID string, packerFormat *string) (interface{}, *_nethttp.Response, error)
- func (self *CiosPubSub) GetObjects(ctx ciosctx.RequestCtx, channelID string, ...) (response cios.MultipleDataStoreObject, httpResponse *_nethttp.Response, ...)
- func (self *CiosPubSub) GetObjectsAll(ctx ciosctx.RequestCtx, channelID string, ...) ([]cios.DataStoreObject, *_nethttp.Response, error)
- func (self *CiosPubSub) GetObjectsUnlimited(ctx ciosctx.RequestCtx, channelID string, ...) ([]cios.DataStoreObject, *_nethttp.Response, error)
- func (self *CiosPubSub) GetOrCreateChannel(ctx ciosctx.RequestCtx, params cios.ApiGetChannelsRequest, ...) (cios.Channel, *_nethttp.Response, error)
- func (self *CiosPubSub) GetStream(ctx ciosctx.RequestCtx, channelID string, params sdkmodel.ApiGetStreamRequest) ([]string, error)
- func (self *CiosPubSub) GetStreamAll(ctx ciosctx.RequestCtx, channelID string, params sdkmodel.ApiGetStreamRequest) ([]string, error)
- func (self *CiosPubSub) GetStreamFirst(ctx ciosctx.RequestCtx, channelID string, params sdkmodel.ApiGetStreamRequest) (string, error)
- func (self *CiosPubSub) GetStreamUnlimited(ctx ciosctx.RequestCtx, channelID string, params sdkmodel.ApiGetStreamRequest) ([]string, error)
- func (self *CiosPubSub) MapMultiObjectLatestPayload(ctx ciosctx.RequestCtx, channelIDs []string, stc interface{}) ([]cios.PackerFormatJsonHeader, *_nethttp.Response, error)
- func (self *CiosPubSub) MapMultiObjectLatestPayloadByChannels(ctx ciosctx.RequestCtx, channels []cios.Channel, stc interface{}) ([]cios.PackerFormatJsonHeader, *_nethttp.Response, error)
- func (self *CiosPubSub) MapObjectLatest(ctx ciosctx.RequestCtx, channelID string, packerFormat *string, ...) (*_nethttp.Response, error)
- func (self *CiosPubSub) MapStreamAll(ctx ciosctx.RequestCtx, channelID string, params sdkmodel.ApiGetStreamRequest, ...) error
- func (self *CiosPubSub) MapStreamFirst(ctx ciosctx.RequestCtx, channelID string, params sdkmodel.ApiGetStreamRequest, ...) error
- func (self *CiosPubSub) MapStreamUnlimited(ctx ciosctx.RequestCtx, channelID string, params sdkmodel.ApiGetStreamRequest, ...) error
- func (self *CiosPubSub) NewMessaging(channelId string, mode enum.MessagingMode, packerFormat enum.PackerFormat) *CiosMessaging
- func (self *CiosPubSub) PublishMessage(ctx ciosctx.RequestCtx, id string, body interface{}, packerFormat *string) (*_nethttp.Response, error)
- func (self *CiosPubSub) PublishMessageJSON(ctx ciosctx.RequestCtx, id string, body cios.PackerFormatJson) (*_nethttp.Response, error)
- func (self *CiosPubSub) PublishMessagePackerOnly(ctx ciosctx.RequestCtx, id string, body interface{}) (*_nethttp.Response, error)
- func (self *CiosPubSub) SetDebug(isDebug bool)
- func (self *CiosPubSub) SetRefresh(refresh func() error)
- func (self *CiosPubSub) SetToken(token string)
- func (self *CiosPubSub) SetWsReadTimeout(wsReadTimeout int64)
- func (self *CiosPubSub) SetWsWriteTimeout(wsWriteTimeout int64)
- func (self *CiosPubSub) UpdateChannel(ctx ciosctx.RequestCtx, channelID string, body cios.ChannelUpdateProposal) (cios.MultipleChannel, *_nethttp.Response, error)
- type ConnectWebSocketOptionsdeprecated
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateCiosWsConn ¶
func MakeGetChannelsOpts ¶
func MakeGetChannelsOpts() cios.ApiGetChannelsRequest
func MakeGetDataStoreChannelsOpts ¶
func MakeGetDataStoreChannelsOpts() cios.ApiGetDataStoreChannelsRequest
func MakeGetObjectsOpts ¶
func MakeGetObjectsOpts() cios.ApiGetDataStoreObjectsRequest
func MakeGetStreamOpts ¶
func MakeGetStreamOpts() sdkmodel.ApiGetStreamRequest
Types ¶
type CiosMessaging ¶
type CiosMessaging struct { SubscribeFunc func([]byte) (bool, error) CloseFunc func() Connection *websocket.Conn // contains filtered or unexported fields }
func (*CiosMessaging) Close ¶
func (self *CiosMessaging) Close() (err error)
func (*CiosMessaging) MapReceived ¶
func (self *CiosMessaging) MapReceived(stct interface{}) error
func (*CiosMessaging) OnClose ¶
func (self *CiosMessaging) OnClose(arg func())
func (*CiosMessaging) OnReceive ¶
func (self *CiosMessaging) OnReceive(arg func([]byte) (bool, error)) error
func (*CiosMessaging) Publish ¶
func (self *CiosMessaging) Publish(message interface{}) error
func (*CiosMessaging) Receive ¶
func (self *CiosMessaging) Receive() (body []byte, err error)
func (*CiosMessaging) ReceiveStr ¶
func (self *CiosMessaging) ReceiveStr() (string, error)
func (*CiosMessaging) Send ¶
func (self *CiosMessaging) Send(message []byte) (err error)
func (*CiosMessaging) SendAny ¶
func (self *CiosMessaging) SendAny(message interface{}) error
func (*CiosMessaging) SendJson ¶
func (self *CiosMessaging) SendJson(message interface{}) error
func (*CiosMessaging) SendStr ¶
func (self *CiosMessaging) SendStr(message string) error
func (*CiosMessaging) SetReadTimeout ¶
func (self *CiosMessaging) SetReadTimeout(t time.Duration) *CiosMessaging
func (*CiosMessaging) SetWriteTimeout ¶
func (self *CiosMessaging) SetWriteTimeout(t time.Duration) *CiosMessaging
func (*CiosMessaging) Start ¶
func (self *CiosMessaging) Start(ctx ciosctx.RequestCtx) (err error)
type CiosPubSub ¶
type CiosPubSub struct { ApiClient *cios.APIClient Url string Host string // contains filtered or unexported fields }
func NewCiosPubSub ¶
func (*CiosPubSub) ConnectWebSocket
deprecated
func (self *CiosPubSub) ConnectWebSocket(channelID string, done chan bool, params ConnectWebSocketOptions) (err error)
Deprecated: should not be used
func (*CiosPubSub) CreateCIOSWebsocketConnection
deprecated
func (*CiosPubSub) CreateChannel ¶
func (self *CiosPubSub) CreateChannel(ctx ciosctx.RequestCtx, body cios.ChannelProposal) (cios.Channel, *_nethttp.Response, error)
func (*CiosPubSub) CreateMessagingURL
deprecated
func (self *CiosPubSub) CreateMessagingURL(channelID string, mode string, packerFormat *string) string
Deprecated: should not be used
func (*CiosPubSub) DeleteChannel ¶
func (self *CiosPubSub) DeleteChannel(ctx ciosctx.RequestCtx, channelID string) (*_nethttp.Response, error)
func (*CiosPubSub) DeleteDataByChannel ¶
func (self *CiosPubSub) DeleteDataByChannel(ctx ciosctx.RequestCtx, channelID string) (*_nethttp.Response, error)
func (*CiosPubSub) DeleteObject ¶
func (self *CiosPubSub) DeleteObject(ctx ciosctx.RequestCtx, channelID string, objectID string) (*_nethttp.Response, error)
func (*CiosPubSub) GetChannel ¶
func (*CiosPubSub) GetChannelFirst ¶
func (self *CiosPubSub) GetChannelFirst(ctx ciosctx.RequestCtx, params cios.ApiGetChannelsRequest) (cios.Channel, *_nethttp.Response, error)
func (*CiosPubSub) GetChannels ¶
func (self *CiosPubSub) GetChannels(ctx ciosctx.RequestCtx, params cios.ApiGetChannelsRequest) (response cios.MultipleChannel, httpResponse *_nethttp.Response, err error)
func (*CiosPubSub) GetChannelsAll ¶
func (self *CiosPubSub) GetChannelsAll(ctx ciosctx.RequestCtx, params cios.ApiGetChannelsRequest) ([]cios.Channel, *_nethttp.Response, error)
func (*CiosPubSub) GetChannelsMapByID ¶
func (self *CiosPubSub) GetChannelsMapByID(ctx ciosctx.RequestCtx, params cios.ApiGetChannelsRequest) (map[string]cios.Channel, *_nethttp.Response, error)
func (*CiosPubSub) GetChannelsMapByResourceOwnerID ¶
func (self *CiosPubSub) GetChannelsMapByResourceOwnerID(ctx ciosctx.RequestCtx, params cios.ApiGetChannelsRequest) (map[string][]cios.Channel, *_nethttp.Response, error)
func (*CiosPubSub) GetChannelsUnlimited ¶
func (self *CiosPubSub) GetChannelsUnlimited(ctx ciosctx.RequestCtx, params cios.ApiGetChannelsRequest) ([]cios.Channel, *_nethttp.Response, error)
func (*CiosPubSub) GetDataStoreChannel ¶
func (self *CiosPubSub) GetDataStoreChannel(ctx ciosctx.RequestCtx, channelID string) (cios.DataStoreChannel, *_nethttp.Response, error)
func (*CiosPubSub) GetDataStoreChannels ¶
func (self *CiosPubSub) GetDataStoreChannels(ctx ciosctx.RequestCtx, params cios.ApiGetDataStoreChannelsRequest) (response cios.MultipleDataStoreChannel, httpResponse *_nethttp.Response, err error)
func (*CiosPubSub) GetJsonStreamUnlimited ¶
func (self *CiosPubSub) GetJsonStreamUnlimited(ctx ciosctx.RequestCtx, channelID string, params sdkmodel.ApiGetStreamRequest) (result []cios.PackerFormatJson, err error)
func (*CiosPubSub) GetMultiObjectLatest ¶
func (self *CiosPubSub) GetMultiObjectLatest(ctx ciosctx.RequestCtx, channelIDs []string) (cios.MultipleDataStoreDataLatest, *_nethttp.Response, error)
func (*CiosPubSub) GetMultiObjectLatestByChannels ¶
func (self *CiosPubSub) GetMultiObjectLatestByChannels(ctx ciosctx.RequestCtx, channels []cios.Channel) (cios.MultipleDataStoreDataLatest, *_nethttp.Response, error)
func (*CiosPubSub) GetObject ¶
func (self *CiosPubSub) GetObject(ctx ciosctx.RequestCtx, channelID string, objectID string, packerFormat *string) (interface{}, *_nethttp.Response, error)
func (*CiosPubSub) GetObjectLatest ¶
func (self *CiosPubSub) GetObjectLatest(ctx ciosctx.RequestCtx, channelID string, packerFormat *string) (interface{}, *_nethttp.Response, error)
func (*CiosPubSub) GetObjects ¶
func (self *CiosPubSub) GetObjects(ctx ciosctx.RequestCtx, channelID string, params cios.ApiGetDataStoreObjectsRequest) (response cios.MultipleDataStoreObject, httpResponse *_nethttp.Response, err error)
func (*CiosPubSub) GetObjectsAll ¶
func (self *CiosPubSub) GetObjectsAll(ctx ciosctx.RequestCtx, channelID string, params cios.ApiGetDataStoreObjectsRequest) ([]cios.DataStoreObject, *_nethttp.Response, error)
func (*CiosPubSub) GetObjectsUnlimited ¶
func (self *CiosPubSub) GetObjectsUnlimited(ctx ciosctx.RequestCtx, channelID string, params cios.ApiGetDataStoreObjectsRequest) ([]cios.DataStoreObject, *_nethttp.Response, error)
func (*CiosPubSub) GetOrCreateChannel ¶
func (self *CiosPubSub) GetOrCreateChannel(ctx ciosctx.RequestCtx, params cios.ApiGetChannelsRequest, body cios.ChannelProposal) (cios.Channel, *_nethttp.Response, error)
func (*CiosPubSub) GetStream ¶
func (self *CiosPubSub) GetStream(ctx ciosctx.RequestCtx, channelID string, params sdkmodel.ApiGetStreamRequest) ([]string, error)
func (*CiosPubSub) GetStreamAll ¶
func (self *CiosPubSub) GetStreamAll(ctx ciosctx.RequestCtx, channelID string, params sdkmodel.ApiGetStreamRequest) ([]string, error)
func (*CiosPubSub) GetStreamFirst ¶
func (self *CiosPubSub) GetStreamFirst(ctx ciosctx.RequestCtx, channelID string, params sdkmodel.ApiGetStreamRequest) (string, error)
func (*CiosPubSub) GetStreamUnlimited ¶
func (self *CiosPubSub) GetStreamUnlimited(ctx ciosctx.RequestCtx, channelID string, params sdkmodel.ApiGetStreamRequest) ([]string, error)
func (*CiosPubSub) MapMultiObjectLatestPayload ¶
func (self *CiosPubSub) MapMultiObjectLatestPayload(ctx ciosctx.RequestCtx, channelIDs []string, stc interface{}) ([]cios.PackerFormatJsonHeader, *_nethttp.Response, error)
func (*CiosPubSub) MapMultiObjectLatestPayloadByChannels ¶
func (self *CiosPubSub) MapMultiObjectLatestPayloadByChannels(ctx ciosctx.RequestCtx, channels []cios.Channel, stc interface{}) ([]cios.PackerFormatJsonHeader, *_nethttp.Response, error)
func (*CiosPubSub) MapObjectLatest ¶
func (self *CiosPubSub) MapObjectLatest(ctx ciosctx.RequestCtx, channelID string, packerFormat *string, stc interface{}) (*_nethttp.Response, error)
func (*CiosPubSub) MapStreamAll ¶
func (self *CiosPubSub) MapStreamAll(ctx ciosctx.RequestCtx, channelID string, params sdkmodel.ApiGetStreamRequest, stc interface{}) error
func (*CiosPubSub) MapStreamFirst ¶
func (self *CiosPubSub) MapStreamFirst(ctx ciosctx.RequestCtx, channelID string, params sdkmodel.ApiGetStreamRequest, stc interface{}) error
func (*CiosPubSub) MapStreamUnlimited ¶
func (self *CiosPubSub) MapStreamUnlimited(ctx ciosctx.RequestCtx, channelID string, params sdkmodel.ApiGetStreamRequest, stc interface{}) error
func (*CiosPubSub) NewMessaging ¶
func (self *CiosPubSub) NewMessaging(channelId string, mode enum.MessagingMode, packerFormat enum.PackerFormat) *CiosMessaging
func (*CiosPubSub) PublishMessage ¶
func (self *CiosPubSub) PublishMessage(ctx ciosctx.RequestCtx, id string, body interface{}, packerFormat *string) (*_nethttp.Response, error)
func (*CiosPubSub) PublishMessageJSON ¶
func (self *CiosPubSub) PublishMessageJSON(ctx ciosctx.RequestCtx, id string, body cios.PackerFormatJson) (*_nethttp.Response, error)
func (*CiosPubSub) PublishMessagePackerOnly ¶
func (self *CiosPubSub) PublishMessagePackerOnly(ctx ciosctx.RequestCtx, id string, body interface{}) (*_nethttp.Response, error)
func (*CiosPubSub) SetDebug ¶
func (self *CiosPubSub) SetDebug(isDebug bool)
func (*CiosPubSub) SetRefresh ¶
func (self *CiosPubSub) SetRefresh(refresh func() error)
func (*CiosPubSub) SetToken ¶
func (self *CiosPubSub) SetToken(token string)
func (*CiosPubSub) SetWsReadTimeout ¶
func (self *CiosPubSub) SetWsReadTimeout(wsReadTimeout int64)
func (*CiosPubSub) SetWsWriteTimeout ¶
func (self *CiosPubSub) SetWsWriteTimeout(wsWriteTimeout int64)
func (*CiosPubSub) UpdateChannel ¶
func (self *CiosPubSub) UpdateChannel(ctx ciosctx.RequestCtx, channelID string, body cios.ChannelUpdateProposal) (cios.MultipleChannel, *_nethttp.Response, error)
type ConnectWebSocketOptions
deprecated
Click to show internal directories.
Click to hide internal directories.