ksqldb

Documentation

Index

• type BodyReader
  • func (_m *BodyReader) Execute(_a0 io.Reader) ([]byte, error)
• type Ksqldb
  • func (_m *Ksqldb) Close()
  • func (_m *Ksqldb) EnableParseSQL(_a0 bool)
  • func (_m *Ksqldb) GetClusterStatus() (*ksqldb.ClusterStatusResponse, error)
  • func (_m *Ksqldb) GetServerInfo() (*ksqldb.KsqlServerInfo, error)
  • func (_m *Ksqldb) GetServerStatus() (*ksqldb.ServerStatusResponse, error)
  • func (_m *Ksqldb) ParseSQLEnabled() bool
  • func (_m *Ksqldb) Pull(_a0 context.Context, _a1 string, _a2 bool) (ksqldb.Header, ksqldb.Payload, error)
  • func (_m *Ksqldb) Push(_a0 context.Context, _a1 string, _a2 chan<- ksqldb.Row, ...) error
  • func (_m *Ksqldb) TerminateCluster(topics ...string) (*ksqldb.KsqlResponseSlice, error)
  • func (_m *Ksqldb) ValidateProperty(property string) (*bool, error)
• type NewClientFactory
  • func (_m *NewClientFactory) NewClient(_a0 net.HTTPClient) (*ksqldb.KsqldbClient, error)
• type NewClientWithOptionsFactory
  • func (_m *NewClientWithOptionsFactory) NewClientWithOptions(options net.Options) (*ksqldb.Ksqldb, error)
• type RespUnmarshaller
  • func (_m *RespUnmarshaller) Execute(_a0 []byte, _a1 interface{}) error

Types

type BodyReader

type BodyReader struct {
	mock.Mock
}

BodyReader is an autogenerated mock type for the BodyReader type

func (*BodyReader) Execute

func (_m *BodyReader) Execute(_a0 io.Reader) ([]byte, error)

Execute provides a mock function with given fields: _a0

type Ksqldb

type Ksqldb struct {
	mock.Mock
}

Ksqldb is an autogenerated mock type for the Ksqldb type

func (*Ksqldb) Close

func (_m *Ksqldb) Close()

Close provides a mock function with given fields:

func (*Ksqldb) EnableParseSQL

func (_m *Ksqldb) EnableParseSQL(_a0 bool)

EnableParseSQL provides a mock function with given fields: _a0

func (*Ksqldb) GetClusterStatus

func (_m *Ksqldb) GetClusterStatus() (*ksqldb.ClusterStatusResponse, error)

GetClusterStatus provides a mock function with given fields:

func (*Ksqldb) GetServerInfo

func (_m *Ksqldb) GetServerInfo() (*ksqldb.KsqlServerInfo, error)

GetServerInfo provides a mock function with given fields:

func (*Ksqldb) GetServerStatus

func (_m *Ksqldb) GetServerStatus() (*ksqldb.ServerStatusResponse, error)

GetServerStatus provides a mock function with given fields:

func (*Ksqldb) ParseSQLEnabled

func (_m *Ksqldb) ParseSQLEnabled() bool

ParseSQLEnabled provides a mock function with given fields:

func (*Ksqldb) Pull

func (_m *Ksqldb) Pull(_a0 context.Context, _a1 string, _a2 bool) (ksqldb.Header, ksqldb.Payload, error)

Pull provides a mock function with given fields: _a0, _a1, _a2

func (*Ksqldb) Push

func (_m *Ksqldb) Push(_a0 context.Context, _a1 string, _a2 chan<- ksqldb.Row, _a3 chan<- ksqldb.Header) error

Push provides a mock function with given fields: _a0, _a1, _a2, _a3

func (*Ksqldb) TerminateCluster

func (_m *Ksqldb) TerminateCluster(topics ...string) (*ksqldb.KsqlResponseSlice, error)

TerminateCluster provides a mock function with given fields: topics

func (*Ksqldb) ValidateProperty

func (_m *Ksqldb) ValidateProperty(property string) (*bool, error)

ValidateProperty provides a mock function with given fields: property

type NewClientFactory

type NewClientFactory struct {
	mock.Mock
}

NewClientFactory is an autogenerated mock type for the NewClientFactory type

func (*NewClientFactory) NewClient

func (_m *NewClientFactory) NewClient(_a0 net.HTTPClient) (*ksqldb.KsqldbClient, error)

NewClient provides a mock function with given fields: _a0

type NewClientWithOptionsFactory

type NewClientWithOptionsFactory struct {
	mock.Mock
}

NewClientWithOptionsFactory is an autogenerated mock type for the NewClientWithOptionsFactory type

func (*NewClientWithOptionsFactory) NewClientWithOptions

func (_m *NewClientWithOptionsFactory) NewClientWithOptions(options net.Options) (*ksqldb.Ksqldb, error)

NewClientWithOptions provides a mock function with given fields: options

type RespUnmarshaller

type RespUnmarshaller struct {
	mock.Mock
}

RespUnmarshaller is an autogenerated mock type for the RespUnmarshaller type

func (*RespUnmarshaller) Execute

func (_m *RespUnmarshaller) Execute(_a0 []byte, _a1 interface{}) error

Execute provides a mock function with given fields: _a0, _a1