client

Documentation

Index

• type SlaitClient
  • func (sc *SlaitClient) DeletePartition(topic, partition string) error
  • func (sc *SlaitClient) GetPartition(topic, partition string, from, to *time.Time, last int) (*rest.PartitionRequestResponse, error)
  • func (sc *SlaitClient) PostTopic(tr rest.TopicsRequest) (err error)
  • func (sc *SlaitClient) PutPartition(topic, partition string, data []byte) error

Types

type SlaitClient

type SlaitClient struct {
	Endpoint string
}

func (*SlaitClient) DeletePartition

func (sc *SlaitClient) DeletePartition(topic, partition string) error

delete a partition

func (*SlaitClient) GetPartition

func (sc *SlaitClient) GetPartition(topic, partition string, from, to *time.Time, last int) (*rest.PartitionRequestResponse, error)

func (*SlaitClient) PostTopic

func (sc *SlaitClient) PostTopic(tr rest.TopicsRequest) (err error)

used for setting up the structure

func (*SlaitClient) PutPartition

func (sc *SlaitClient) PutPartition(topic, partition string, data []byte) error

used for delivering the data