proto

Documentation

Index

• type OutputStreamServer
  • func (s *OutputStreamServer) CheckFieldId(_ context.Context, req *pb.CheckFieldIdRequest) (*pb.CheckFieldIdResponse, error)
  • func (s *OutputStreamServer) Dump(_ context.Context, req *pb.DumpRequest) (*pb.DumpResponse, error)
  • func (s *OutputStreamServer) End(_ context.Context, req *pb.EndRequest) (*pb.EndResponse, error)
  • func (s *OutputStreamServer) Flush(_ context.Context, req *pb.FlushRequest) (*pb.FlushResponse, error)
  • func (s *OutputStreamServer) GetBytes(_ context.Context, req *pb.GetBytesRequest) (*pb.GetBytesResponse, error)
  • func (s *OutputStreamServer) GetFieldCountString(_ context.Context, req *pb.GetFieldCountStringRequest) (*pb.GetFieldCountStringResponse, error)
  • func (s *OutputStreamServer) GetFieldIdString(_ context.Context, req *pb.GetFieldIdStringRequest) (*pb.GetFieldIdStringResponse, error)
  • func (s *OutputStreamServer) GetFieldTypeString(_ context.Context, req *pb.GetFieldTypeStringRequest) (*pb.GetFieldTypeStringResponse, error)
  • func (s *OutputStreamServer) GetRawSize(_ context.Context, req *pb.GetRawSizeRequest) (*pb.GetRawSizeResponse, error)
  • func (s *OutputStreamServer) GetWireTypeString(_ context.Context, req *pb.GetWireTypeStringRequest) (*pb.GetWireTypeStringResponse, error)
  • func (s *OutputStreamServer) MakeFieldId(_ context.Context, req *pb.MakeFieldIdRequest) (*pb.MakeFieldIdResponse, error)
  • func (s *OutputStreamServer) MakeToken(_ context.Context, req *pb.MakeTokenRequest) (*pb.MakeTokenResponse, error)
  • func (s *OutputStreamServer) NewOutputStream(_ context.Context, req *pb.NewOutputStreamRequest) (*pb.NewOutputStreamResponse, error)
  • func (s *OutputStreamServer) Start(_ context.Context, req *pb.StartRequest) (*pb.StartResponse, error)
  • func (s *OutputStreamServer) Token2String(_ context.Context, req *pb.Token2StringRequest) (*pb.Token2StringResponse, error)
  • func (s *OutputStreamServer) Write2(_ context.Context, req *pb.Write2Request) (*pb.Write2Response, error)
  • func (s *OutputStreamServer) Write2_1(_ context.Context, req *pb.Write2_1Request) (*pb.Write2_1Response, error)
  • func (s *OutputStreamServer) Write2_2(_ context.Context, req *pb.Write2_2Request) (*pb.Write2_2Response, error)
  • func (s *OutputStreamServer) Write2_3(_ context.Context, req *pb.Write2_3Request) (*pb.Write2_3Response, error)
  • func (s *OutputStreamServer) Write2_4(_ context.Context, req *pb.Write2_4Request) (*pb.Write2_4Response, error)
  • func (s *OutputStreamServer) Write2_5(_ context.Context, req *pb.Write2_5Request) (*pb.Write2_5Response, error)
  • func (s *OutputStreamServer) Write2_6(_ context.Context, req *pb.Write2_6Request) (*pb.Write2_6Response, error)
  • func (s *OutputStreamServer) WriteTag(_ context.Context, req *pb.WriteTagRequest) (*pb.WriteTagResponse, error)

Types

type OutputStreamServer

type OutputStreamServer struct {
	pb.UnimplementedOutputStreamServiceServer
	Ctx     *app.Context
	Handles *handlestore.HandleStore
}

OutputStreamServer implements pb.OutputStreamServiceServer.

func (*OutputStreamServer) CheckFieldId

func (s *OutputStreamServer) CheckFieldId(_ context.Context, req *pb.CheckFieldIdRequest) (*pb.CheckFieldIdResponse, error)

func (*OutputStreamServer) Dump

func (s *OutputStreamServer) Dump(_ context.Context, req *pb.DumpRequest) (*pb.DumpResponse, error)

func (*OutputStreamServer) End

func (s *OutputStreamServer) End(_ context.Context, req *pb.EndRequest) (*pb.EndResponse, error)

func (*OutputStreamServer) Flush

func (s *OutputStreamServer) Flush(_ context.Context, req *pb.FlushRequest) (*pb.FlushResponse, error)

func (*OutputStreamServer) GetBytes

func (s *OutputStreamServer) GetBytes(_ context.Context, req *pb.GetBytesRequest) (*pb.GetBytesResponse, error)

func (*OutputStreamServer) GetFieldCountString

func (s *OutputStreamServer) GetFieldCountString(_ context.Context, req *pb.GetFieldCountStringRequest) (*pb.GetFieldCountStringResponse, error)

func (*OutputStreamServer) GetFieldIdString

func (s *OutputStreamServer) GetFieldIdString(_ context.Context, req *pb.GetFieldIdStringRequest) (*pb.GetFieldIdStringResponse, error)

func (*OutputStreamServer) GetFieldTypeString

func (s *OutputStreamServer) GetFieldTypeString(_ context.Context, req *pb.GetFieldTypeStringRequest) (*pb.GetFieldTypeStringResponse, error)

func (*OutputStreamServer) GetRawSize

func (s *OutputStreamServer) GetRawSize(_ context.Context, req *pb.GetRawSizeRequest) (*pb.GetRawSizeResponse, error)

func (*OutputStreamServer) GetWireTypeString

func (s *OutputStreamServer) GetWireTypeString(_ context.Context, req *pb.GetWireTypeStringRequest) (*pb.GetWireTypeStringResponse, error)

func (*OutputStreamServer) MakeFieldId

func (s *OutputStreamServer) MakeFieldId(_ context.Context, req *pb.MakeFieldIdRequest) (*pb.MakeFieldIdResponse, error)

func (*OutputStreamServer) MakeToken

func (s *OutputStreamServer) MakeToken(_ context.Context, req *pb.MakeTokenRequest) (*pb.MakeTokenResponse, error)

func (*OutputStreamServer) NewOutputStream

func (s *OutputStreamServer) NewOutputStream(_ context.Context, req *pb.NewOutputStreamRequest) (*pb.NewOutputStreamResponse, error)

func (*OutputStreamServer) Start

func (s *OutputStreamServer) Start(_ context.Context, req *pb.StartRequest) (*pb.StartResponse, error)

func (*OutputStreamServer) Token2String

func (s *OutputStreamServer) Token2String(_ context.Context, req *pb.Token2StringRequest) (*pb.Token2StringResponse, error)

func (*OutputStreamServer) Write2

func (s *OutputStreamServer) Write2(_ context.Context, req *pb.Write2Request) (*pb.Write2Response, error)

func (*OutputStreamServer) Write2_1

func (s *OutputStreamServer) Write2_1(_ context.Context, req *pb.Write2_1Request) (*pb.Write2_1Response, error)

func (*OutputStreamServer) Write2_2

func (s *OutputStreamServer) Write2_2(_ context.Context, req *pb.Write2_2Request) (*pb.Write2_2Response, error)

func (*OutputStreamServer) Write2_3

func (s *OutputStreamServer) Write2_3(_ context.Context, req *pb.Write2_3Request) (*pb.Write2_3Response, error)

func (*OutputStreamServer) Write2_4

func (s *OutputStreamServer) Write2_4(_ context.Context, req *pb.Write2_4Request) (*pb.Write2_4Response, error)

func (*OutputStreamServer) Write2_5

func (s *OutputStreamServer) Write2_5(_ context.Context, req *pb.Write2_5Request) (*pb.Write2_5Response, error)

func (*OutputStreamServer) Write2_6

func (s *OutputStreamServer) Write2_6(_ context.Context, req *pb.Write2_6Request) (*pb.Write2_6Response, error)

func (*OutputStreamServer) WriteTag

func (s *OutputStreamServer) WriteTag(_ context.Context, req *pb.WriteTagRequest) (*pb.WriteTagResponse, error)