server

Documentation

Index

• type HeadServer
  • func (s *HeadServer) Get(ctx context.Context, request *pb.GetRequest) (*pb.GetReply, error)
  • func (s *HeadServer) Set(ctx context.Context, request *pb.SetRequest) (*pb.SetReply, error)

Types

type HeadServer

type HeadServer struct {
	pb.HeadServer
	Config           config.Config
	KafkaProducer    kafka.Producer
	ClickhouseClient clickhouse.Client
}

func (*HeadServer) Get

func (s *HeadServer) Get(ctx context.Context, request *pb.GetRequest) (*pb.GetReply, error)

func (*HeadServer) Set

func (s *HeadServer) Set(ctx context.Context, request *pb.SetRequest) (*pb.SetReply, error)