di

Documentation

Index

• type Container
  • func NewContainer(cfg *utils.MktsConfig) *Container
  • func (c *Container) GetAbsRootDir() string
  • func (c *Container) GetAggRunner() *sqlparser.AggRunner
  • func (c *Container) GetCatalogDir() *catalog.Directory
  • func (c *Container) GetDefaultWriter() frontend.Writer
  • func (c *Container) GetGRPCReplicationServer() *grpc.Server
  • func (c *Container) GetGRPCServer() *grpc.Server
  • func (c *Container) GetGRPCServerOptions() []grpc.ServerOption
  • func (c *Container) GetGRPCService() *frontend.GRPCService
  • func (c *Container) GetHTTPServer() *frontend.RPCServer
  • func (c *Container) GetHTTPService() *frontend.QueryService
  • func (c *Container) GetInitInstanceID() int64
  • func (c *Container) GetInitWALFile() *executor.WALFileType
  • func (c *Container) GetReplicationClientWithRetry() ReplicationClient
  • func (c *Container) GetReplicationSender() executor.ReplicationSender
  • func (c *Container) GetReplicationServer() *replication.GRPCReplicationServer
  • func (c *Container) GetStartTriggerPluginDispatcher() *executor.TriggerPluginDispatcher
  • func (c *Container) GetTriggerMatchers() []*trigger.Matcher
  • func (c *Container) GetWriter() frontend.Writer
  • func (c *Container) InjectTriggerMatchers(ms []*trigger.Matcher)
• type NopReplicationClient
  • func (nrc *NopReplicationClient) Run(_ context.Context) error
• type ReplicationClient

Types

type Container

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

func NewContainer

func NewContainer(cfg *utils.MktsConfig) *Container

func (*Container) GetAbsRootDir

func (c *Container) GetAbsRootDir() string

func (*Container) GetAggRunner

func (c *Container) GetAggRunner() *sqlparser.AggRunner

GetAggRunner gets Aggregation Functions registry.

func (*Container) GetCatalogDir

func (c *Container) GetCatalogDir() *catalog.Directory

func (*Container) GetDefaultWriter

func (c *Container) GetDefaultWriter() frontend.Writer

GetDefaultWriter returns a writable writer. Replica instances can use it only for data writes for replication.

func (*Container) GetGRPCReplicationServer

func (c *Container) GetGRPCReplicationServer() *grpc.Server

func (*Container) GetGRPCServer

func (c *Container) GetGRPCServer() *grpc.Server

GetGRPCServer returns the grpc server for marketstore API.

func (*Container) GetGRPCServerOptions

func (c *Container) GetGRPCServerOptions() []grpc.ServerOption

func (*Container) GetGRPCService

func (c *Container) GetGRPCService() *frontend.GRPCService

func (*Container) GetHTTPServer

func (c *Container) GetHTTPServer() *frontend.RPCServer

func (*Container) GetHTTPService

func (c *Container) GetHTTPService() *frontend.QueryService

func (*Container) GetInitInstanceID

func (c *Container) GetInitInstanceID() int64

func (*Container) GetInitWALFile

func (c *Container) GetInitWALFile() *executor.WALFileType

func (*Container) GetReplicationClientWithRetry

func (c *Container) GetReplicationClientWithRetry() ReplicationClient

func (*Container) GetReplicationSender

func (c *Container) GetReplicationSender() executor.ReplicationSender

func (*Container) GetReplicationServer

func (c *Container) GetReplicationServer() *replication.GRPCReplicationServer

func (*Container) GetStartTriggerPluginDispatcher

func (c *Container) GetStartTriggerPluginDispatcher() *executor.TriggerPluginDispatcher

func (*Container) GetTriggerMatchers

func (c *Container) GetTriggerMatchers() []*trigger.Matcher

func (*Container) GetWriter

func (c *Container) GetWriter() frontend.Writer

GetWriter returns a CSM writer. it returns ErrorWriter to replica instances because write API is disabled on replicas.

func (*Container) InjectTriggerMatchers

func (c *Container) InjectTriggerMatchers(ms []*trigger.Matcher)

type NopReplicationClient

type NopReplicationClient struct{}

func (*NopReplicationClient) Run

func (nrc *NopReplicationClient) Run(_ context.Context) error

type ReplicationClient

type ReplicationClient interface {
	Run(ctx context.Context) error
}