connector

Documentation

Index

• type Config
• type Connector
  • func NewRPC(accesslogClient *accesslog.ProducerClient, ...) *Connector
  • func (c *Connector) AccesslogProduceLog(args *types.AccesslogProduceLogArgs, _ *struct{}) error
  • func (c *Connector) ControlCheckAccountPaused(args *types.CheckAccountPausedArgs, reply *types.CheckAccountPausedReply) error
  • func (c *Connector) ControlCheckKey(args *types.ControlCheckKeyArgs, reply *types.ControlCheckKeyReply) error

Types

type Config

type Config struct {
	Listen string `yaml:"listen"`

	// Access Log Report
	KafkaBrokers []string `yaml:"kafka_brokers"`
	KafkaTopic   string   `yaml:"kafka_topic"`

	// State management
	EtcdEndpoints []string `yaml:"etcd_endpoints"`
	EtcdUsername  *string  `yaml:"etcd_username"`
	EtcdPassword  *string  `yaml:"etcd_password"`
}

type Connector

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

func NewRPC

func NewRPC(accesslogClient *accesslog.ProducerClient, controlClient *control.StateClientReader) *Connector

func (*Connector) AccesslogProduceLog

func (c *Connector) AccesslogProduceLog(args *types.AccesslogProduceLogArgs, _ *struct{}) error

func (*Connector) ControlCheckAccountPaused

func (c *Connector) ControlCheckAccountPaused(args *types.CheckAccountPausedArgs, reply *types.CheckAccountPausedReply) error

func (*Connector) ControlCheckKey

func (c *Connector) ControlCheckKey(args *types.ControlCheckKeyArgs, reply *types.ControlCheckKeyReply) error