ksql

Documentation

Index

• func Provider() *schema.Provider
• type Client
  • func NewClient(url string, username string, password string) *Client
  • func NewClientContext(ctx context.Context, url string, username string, password string) *Client
  • func (ksql *Client) CreateStream(streamName string, query string) (Response, error)
  • func (ksql *Client) DropStream(streamName string) (Response, error)
  • func (ksql *Client) GetStreamByName(streamName string) (*Stream, error)
  • func (ksql *Client) GetStreamsByTag(tag string) ([]Stream, error)
  • func (ksql *Client) GetStreamsByTopic(topicName string) ([]Stream, error)
  • func (ksql *Client) ListStreams() ([]Stream, error)
• type CommandStatus
• type Payload
• type Response
• type Stream

Functions

func Provider

func Provider() *schema.Provider

Types

type Client

type Client struct {
	context.Context
	// contains filtered or unexported fields
}

func NewClient

func NewClient(url string, username string, password string) *Client

func NewClientContext

func NewClientContext(ctx context.Context, url string, username string, password string) *Client

func (*Client) CreateStream

func (ksql *Client) CreateStream(streamName string, query string) (Response, error)

func (*Client) DropStream

func (ksql *Client) DropStream(streamName string) (Response, error)

func (*Client) GetStreamByName

func (ksql *Client) GetStreamByName(streamName string) (*Stream, error)

func (*Client) GetStreamsByTag

func (ksql *Client) GetStreamsByTag(tag string) ([]Stream, error)

func (*Client) GetStreamsByTopic

func (ksql *Client) GetStreamsByTopic(topicName string) ([]Stream, error)

func (*Client) ListStreams

func (ksql *Client) ListStreams() ([]Stream, error)

type CommandStatus

type CommandStatus struct {
	Status  string `json:"status"`
	Message string `json:"message"`
}

type Payload

type Payload struct {
	Ksql string `json:"ksql"`
}

type Response

type Response []struct {
	Streams       []Stream      `json:"streams"`
	CommandStatus CommandStatus `json:"commandStatus"`
	ErrorCode     int           `json:"error_code"`
	Message       string        `json:"message"`
}

type Stream

type Stream struct {
	Name  string `json:"name"`
	Topic string `json:"topic"`
}