edge

Documentation

Index

• type EdgeServiceServer
  • func NewEdgeServiceServer(log *zap.Logger, rbmq *amqp.Connection) *EdgeServiceServer
  • func (s *EdgeServiceServer) PostState(ctx context.Context, req *stpb.ObjectState) (*pb.Empty, error)
  • func (s *EdgeServiceServer) Test(ctx context.Context, _ *pb.TestRequest) (*pb.TestResponse, error)

Types

type EdgeServiceServer

type EdgeServiceServer struct {
	pb.UnimplementedEdgeServiceServer
	// contains filtered or unexported fields
}

func NewEdgeServiceServer

func NewEdgeServiceServer(log *zap.Logger, rbmq *amqp.Connection) *EdgeServiceServer

func (*EdgeServiceServer) PostState

func (s *EdgeServiceServer) PostState(ctx context.Context, req *stpb.ObjectState) (*pb.Empty, error)

func (*EdgeServiceServer) Test

func (s *EdgeServiceServer) Test(ctx context.Context, _ *pb.TestRequest) (*pb.TestResponse, error)