Documentation
¶
Index ¶
- Constants
- type ChannelRef
- func (c *ChannelRef) Close() error
- func (c *ChannelRef) Connect(ctx context.Context) error
- func (c *ChannelRef) Create(ctx context.Context) (dtos.ChannelDTO, error)
- func (c *ChannelRef) Exists(ctx context.Context) (bool, error)
- func (c *ChannelRef) Get(ctx context.Context) (dtos.ChannelDTO, error)
- func (c *ChannelRef) Name() string
- type Client
- type ClientAuthorization
- type ClientOptions
Constants ¶
View Source
const (
ChannelEntityType = "Channel"
)
View Source
const (
DefaultTimeout = 10 * time.Second
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChannelRef ¶
type ChannelRef struct {
// contains filtered or unexported fields
}
func NewChannelRef ¶
func NewChannelRef(name string, client *Client) *ChannelRef
func (*ChannelRef) Close ¶
func (c *ChannelRef) Close() error
func (*ChannelRef) Connect ¶
func (c *ChannelRef) Connect(ctx context.Context) error
TODO: Review return type
func (*ChannelRef) Create ¶
func (c *ChannelRef) Create(ctx context.Context) (dtos.ChannelDTO, error)
func (*ChannelRef) Get ¶
func (c *ChannelRef) Get(ctx context.Context) (dtos.ChannelDTO, error)
func (*ChannelRef) Name ¶
func (c *ChannelRef) Name() string
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func NewClient ¶
func NewClient(options ClientOptions) *Client
func (*Client) Channel ¶
func (c *Client) Channel(name string) *ChannelRef
type ClientAuthorization ¶
type ClientAuthorization struct {
ApiToken string
}
type ClientOptions ¶
Click to show internal directories.
Click to hide internal directories.