components

Documentation

Index

• type DataCoord
  • func NewDataCoord(ctx context.Context, factory dependency.Factory) (*DataCoord, error)
  • func (s *DataCoord) GetName() string
  • func (s *DataCoord) Health(ctx context.Context) commonpb.StateCode
  • func (s *DataCoord) Run() error
  • func (s *DataCoord) Stop() error
• type DataNode
  • func NewDataNode(ctx context.Context, factory dependency.Factory) (*DataNode, error)
  • func (d *DataNode) GetName() string
  • func (d *DataNode) Health(ctx context.Context) commonpb.StateCode
  • func (d *DataNode) Run() error
  • func (d *DataNode) Stop() error
• type IndexCoord
  • func NewIndexCoord(ctx context.Context, factory dependency.Factory) (*IndexCoord, error)
  • func (s *IndexCoord) GetName() string
  • func (s *IndexCoord) Health(ctx context.Context) commonpb.StateCode
  • func (s *IndexCoord) Run() error
  • func (s *IndexCoord) Stop() error
• type IndexNode
  • func NewIndexNode(ctx context.Context, factory dependency.Factory) (*IndexNode, error)
  • func (n *IndexNode) GetName() string
  • func (n *IndexNode) Health(ctx context.Context) commonpb.StateCode
  • func (n *IndexNode) Run() error
  • func (n *IndexNode) Stop() error
• type Proxy
  • func NewProxy(ctx context.Context, factory dependency.Factory) (*Proxy, error)
  • func (n *Proxy) GetName() string
  • func (n *Proxy) Health(ctx context.Context) commonpb.StateCode
  • func (n *Proxy) Run() error
  • func (n *Proxy) Stop() error
• type QueryCoord
  • func NewQueryCoord(ctx context.Context, factory dependency.Factory) (*QueryCoord, error)
  • func (qs *QueryCoord) GetName() string
  • func (qs *QueryCoord) Health(ctx context.Context) commonpb.StateCode
  • func (qs *QueryCoord) Run() error
  • func (qs *QueryCoord) Stop() error
• type QueryNode
  • func NewQueryNode(ctx context.Context, factory dependency.Factory) (*QueryNode, error)
  • func (q *QueryNode) GetName() string
  • func (q *QueryNode) Health(ctx context.Context) commonpb.StateCode
  • func (q *QueryNode) Run() error
  • func (q *QueryNode) Stop() error
• type RootCoord
  • func NewRootCoord(ctx context.Context, factory dependency.Factory) (*RootCoord, error)
  • func (rc *RootCoord) GetName() string
  • func (rc *RootCoord) Health(ctx context.Context) commonpb.StateCode
  • func (rc *RootCoord) Run() error
  • func (rc *RootCoord) Stop() error
• type StreamingNode
  • func NewStreamingNode(_ context.Context, _ dependency.Factory) (*StreamingNode, error)
  • func (q *StreamingNode) GetName() string

Types

type DataCoord

type DataCoord struct {
	// contains filtered or unexported fields
}

DataCoord implements grpc server of DataCoord server

func NewDataCoord

func NewDataCoord(ctx context.Context, factory dependency.Factory) (*DataCoord, error)

NewDataCoord creates a new DataCoord

func (*DataCoord) GetName

func (s *DataCoord) GetName() string

func (*DataCoord) Health

func (s *DataCoord) Health(ctx context.Context) commonpb.StateCode

GetComponentStates returns DataCoord's states

func (*DataCoord) Run

func (s *DataCoord) Run() error

Run starts service

func (*DataCoord) Stop

func (s *DataCoord) Stop() error

Stop terminates service

type DataNode

type DataNode struct {
	// contains filtered or unexported fields
}

DataNode implements DataNode grpc server

func NewDataNode

func NewDataNode(ctx context.Context, factory dependency.Factory) (*DataNode, error)

NewDataNode creates a new DataNode

func (*DataNode) GetName

func (d *DataNode) GetName() string

func (*DataNode) Health

func (d *DataNode) Health(ctx context.Context) commonpb.StateCode

GetComponentStates returns DataNode's states

func (*DataNode) Run

func (d *DataNode) Run() error

Run starts service

func (*DataNode) Stop

func (d *DataNode) Stop() error

Stop terminates service

type IndexCoord

type IndexCoord struct{}

IndexCoord implements IndexCoord grpc server

func NewIndexCoord

func NewIndexCoord(ctx context.Context, factory dependency.Factory) (*IndexCoord, error)

NewIndexCoord creates a new IndexCoord

func (*IndexCoord) GetName

func (s *IndexCoord) GetName() string

func (*IndexCoord) Health

func (s *IndexCoord) Health(ctx context.Context) commonpb.StateCode

GetComponentStates returns indexnode's states

func (*IndexCoord) Run

func (s *IndexCoord) Run() error

Run starts service

func (*IndexCoord) Stop

func (s *IndexCoord) Stop() error

Stop terminates service

type IndexNode

type IndexNode struct {
	// contains filtered or unexported fields
}

IndexNode implements IndexNode grpc server

func NewIndexNode

func NewIndexNode(ctx context.Context, factory dependency.Factory) (*IndexNode, error)

NewIndexNode creates a new IndexNode

func (*IndexNode) GetName

func (n *IndexNode) GetName() string

func (*IndexNode) Health

func (n *IndexNode) Health(ctx context.Context) commonpb.StateCode

GetComponentStates returns IndexNode's states

func (*IndexNode) Run

func (n *IndexNode) Run() error

Run starts service

func (*IndexNode) Stop

func (n *IndexNode) Stop() error

Stop terminates service

type Proxy

type Proxy struct {
	// contains filtered or unexported fields
}

Proxy implements Proxy grpc server

func NewProxy

func NewProxy(ctx context.Context, factory dependency.Factory) (*Proxy, error)

NewProxy creates a new Proxy

func (*Proxy) GetName

func (n *Proxy) GetName() string

func (*Proxy) Health

func (n *Proxy) Health(ctx context.Context) commonpb.StateCode

GetComponentStates returns Proxy's states

func (*Proxy) Run

func (n *Proxy) Run() error

Run starts service

func (*Proxy) Stop

func (n *Proxy) Stop() error

Stop terminates service

type QueryCoord

type QueryCoord struct {
	// contains filtered or unexported fields
}

QueryCoord implements QueryCoord grpc server

func NewQueryCoord

func NewQueryCoord(ctx context.Context, factory dependency.Factory) (*QueryCoord, error)

NewQueryCoord creates a new QueryCoord

func (*QueryCoord) GetName

func (qs *QueryCoord) GetName() string

func (*QueryCoord) Health

func (qs *QueryCoord) Health(ctx context.Context) commonpb.StateCode

GetComponentStates returns QueryCoord's states

func (*QueryCoord) Run

func (qs *QueryCoord) Run() error

Run starts service

func (*QueryCoord) Stop

func (qs *QueryCoord) Stop() error

Stop terminates service

type QueryNode

type QueryNode struct {
	// contains filtered or unexported fields
}

QueryNode implements QueryNode grpc server

func NewQueryNode

func NewQueryNode(ctx context.Context, factory dependency.Factory) (*QueryNode, error)

NewQueryNode creates a new QueryNode

func (*QueryNode) GetName

func (q *QueryNode) GetName() string

func (*QueryNode) Health

func (q *QueryNode) Health(ctx context.Context) commonpb.StateCode

GetComponentStates returns QueryNode's states

func (*QueryNode) Run

func (q *QueryNode) Run() error

Run starts service

func (*QueryNode) Stop

func (q *QueryNode) Stop() error

Stop terminates service

type RootCoord

type RootCoord struct {
	// contains filtered or unexported fields
}

RootCoord implements RoodCoord grpc server

func NewRootCoord

func NewRootCoord(ctx context.Context, factory dependency.Factory) (*RootCoord, error)

NewRootCoord creates a new RoorCoord

func (*RootCoord) GetName

func (rc *RootCoord) GetName() string

func (*RootCoord) Health

func (rc *RootCoord) Health(ctx context.Context) commonpb.StateCode

GetComponentStates returns RootCoord's states

func (*RootCoord) Run

func (rc *RootCoord) Run() error

Run starts service

func (*RootCoord) Stop

func (rc *RootCoord) Stop() error

Stop terminates service

type StreamingNode

type StreamingNode struct {
	*streamingnode.Server
}

func NewStreamingNode

func NewStreamingNode(_ context.Context, _ dependency.Factory) (*StreamingNode, error)

NewStreamingNode creates a new StreamingNode

func (*StreamingNode) GetName

func (q *StreamingNode) GetName() string