v1

Documentation

Index

• Variables
• func RegisterSagaAdminServer(s *grpc.Server, srv SagaAdminServer)
• type PushMsgReply
  • func (*PushMsgReply) Descriptor() ([]byte, []int)
  • func (m *PushMsgReply) Marshal() (dAtA []byte, err error)
  • func (m *PushMsgReply) MarshalTo(dAtA []byte) (int, error)
  • func (*PushMsgReply) ProtoMessage()
  • func (m *PushMsgReply) Reset()
  • func (m *PushMsgReply) Size() (n int)
  • func (m *PushMsgReply) String() string
  • func (m *PushMsgReply) Unmarshal(dAtA []byte) error
  • func (m *PushMsgReply) XXX_DiscardUnknown()
  • func (m *PushMsgReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (dst *PushMsgReply) XXX_Merge(src proto.Message)
  • func (m *PushMsgReply) XXX_Size() int
  • func (m *PushMsgReply) XXX_Unmarshal(b []byte) error
• type PushMsgReq
  • func (*PushMsgReq) Descriptor() ([]byte, []int)
  • func (m *PushMsgReq) GetContent() string
  • func (m *PushMsgReq) GetUsername() []string
  • func (m *PushMsgReq) Marshal() (dAtA []byte, err error)
  • func (m *PushMsgReq) MarshalTo(dAtA []byte) (int, error)
  • func (*PushMsgReq) ProtoMessage()
  • func (m *PushMsgReq) Reset()
  • func (m *PushMsgReq) Size() (n int)
  • func (m *PushMsgReq) String() string
  • func (m *PushMsgReq) Unmarshal(dAtA []byte) error
  • func (m *PushMsgReq) XXX_DiscardUnknown()
  • func (m *PushMsgReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (dst *PushMsgReq) XXX_Merge(src proto.Message)
  • func (m *PushMsgReq) XXX_Size() int
  • func (m *PushMsgReq) XXX_Unmarshal(b []byte) error
• type SagaAdminClient
  • func NewSagaAdminClient(cc *grpc.ClientConn) SagaAdminClient
• type SagaAdminServer

Variables

var (
	ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowApi   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterSagaAdminServer

func RegisterSagaAdminServer(s *grpc.Server, srv SagaAdminServer)

Types

type PushMsgReply

type PushMsgReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PushMsgReply) Descriptor

func (*PushMsgReply) Descriptor() ([]byte, []int)

func (*PushMsgReply) Marshal

func (m *PushMsgReply) Marshal() (dAtA []byte, err error)

func (*PushMsgReply) MarshalTo

func (m *PushMsgReply) MarshalTo(dAtA []byte) (int, error)

func (*PushMsgReply) ProtoMessage

func (*PushMsgReply) ProtoMessage()

func (*PushMsgReply) Reset

func (m *PushMsgReply) Reset()

func (*PushMsgReply) Size

func (m *PushMsgReply) Size() (n int)

func (*PushMsgReply) String

func (m *PushMsgReply) String() string

func (*PushMsgReply) Unmarshal

func (m *PushMsgReply) Unmarshal(dAtA []byte) error

func (*PushMsgReply) XXX_DiscardUnknown

func (m *PushMsgReply) XXX_DiscardUnknown()

func (*PushMsgReply) XXX_Marshal

func (m *PushMsgReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PushMsgReply) XXX_Merge

func (dst *PushMsgReply) XXX_Merge(src proto.Message)

func (*PushMsgReply) XXX_Size

func (m *PushMsgReply) XXX_Size() int

func (*PushMsgReply) XXX_Unmarshal

func (m *PushMsgReply) XXX_Unmarshal(b []byte) error

type PushMsgReq

type PushMsgReq struct {
	Username             []string `protobuf:"bytes,1,rep,name=username" json:"username,omitempty"`
	Content              string   `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PushMsgReq) Descriptor

func (*PushMsgReq) Descriptor() ([]byte, []int)

func (*PushMsgReq) GetContent

func (m *PushMsgReq) GetContent() string

func (*PushMsgReq) GetUsername

func (m *PushMsgReq) GetUsername() []string

func (*PushMsgReq) Marshal

func (m *PushMsgReq) Marshal() (dAtA []byte, err error)

func (*PushMsgReq) MarshalTo

func (m *PushMsgReq) MarshalTo(dAtA []byte) (int, error)

func (*PushMsgReq) ProtoMessage

func (*PushMsgReq) ProtoMessage()

func (*PushMsgReq) Reset

func (m *PushMsgReq) Reset()

func (*PushMsgReq) Size

func (m *PushMsgReq) Size() (n int)

func (*PushMsgReq) String

func (m *PushMsgReq) String() string

func (*PushMsgReq) Unmarshal

func (m *PushMsgReq) Unmarshal(dAtA []byte) error

func (*PushMsgReq) XXX_DiscardUnknown

func (m *PushMsgReq) XXX_DiscardUnknown()

func (*PushMsgReq) XXX_Marshal

func (m *PushMsgReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PushMsgReq) XXX_Merge

func (dst *PushMsgReq) XXX_Merge(src proto.Message)

func (*PushMsgReq) XXX_Size

func (m *PushMsgReq) XXX_Size() int

func (*PushMsgReq) XXX_Unmarshal

func (m *PushMsgReq) XXX_Unmarshal(b []byte) error

type SagaAdminClient

type SagaAdminClient interface {
	PushMsg(ctx context.Context, in *PushMsgReq, opts ...grpc.CallOption) (*PushMsgReply, error)
}

SagaAdminClient is the client API for SagaAdmin service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSagaAdminClient

func NewSagaAdminClient(cc *grpc.ClientConn) SagaAdminClient

type SagaAdminServer

type SagaAdminServer interface {
	PushMsg(context.Context, *PushMsgReq) (*PushMsgReply, error)
}

SagaAdminServer is the server API for SagaAdmin service.