v1

package
v0.0.0-...-b3a6344 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 4, 2019 License: GPL-3.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterMessageCommandServiceServer 

func RegisterMessageCommandServiceServer(s *grpc.Server, srv MessageCommandServiceServer)

func RegisterMessageQueryServiceServer 

func RegisterMessageQueryServiceServer(s *grpc.Server, srv MessageQueryServiceServer)

Types

type CreateMessageRequest 

type CreateMessageRequest struct {
	Message              *Message `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateMessageRequest) Descriptor 

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

func (*CreateMessageRequest) GetMessage 

func (m *CreateMessageRequest) GetMessage() *Message

func (*CreateMessageRequest) ProtoMessage 

func (*CreateMessageRequest) ProtoMessage()

func (*CreateMessageRequest) Reset 

func (m *CreateMessageRequest) Reset()

func (*CreateMessageRequest) String 

func (m *CreateMessageRequest) String() string

func (*CreateMessageRequest) XXX_DiscardUnknown 

func (m *CreateMessageRequest) XXX_DiscardUnknown()

func (*CreateMessageRequest) XXX_Marshal 

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

func (*CreateMessageRequest) XXX_Merge 

func (m *CreateMessageRequest) XXX_Merge(src proto.Message)

func (*CreateMessageRequest) XXX_Size 

func (m *CreateMessageRequest) XXX_Size() int

func (*CreateMessageRequest) XXX_Unmarshal 

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

type ListMessagesRequest 

type ListMessagesRequest struct {
	StakeholderId        int64    `protobuf:"varint,1,opt,name=stakeholder_id,json=stakeholderId,proto3" json:"stakeholder_id,omitempty"`
	PageNumber           int32    `protobuf:"varint,2,opt,name=page_number,json=pageNumber,proto3" json:"page_number,omitempty"`
	ResultPerPage        int32    `protobuf:"varint,3,opt,name=result_per_page,json=resultPerPage,proto3" json:"result_per_page,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListMessagesRequest) Descriptor 

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

func (*ListMessagesRequest) GetPageNumber 

func (m *ListMessagesRequest) GetPageNumber() int32

func (*ListMessagesRequest) GetResultPerPage 

func (m *ListMessagesRequest) GetResultPerPage() int32

func (*ListMessagesRequest) GetStakeholderId 

func (m *ListMessagesRequest) GetStakeholderId() int64

func (*ListMessagesRequest) ProtoMessage 

func (*ListMessagesRequest) ProtoMessage()

func (*ListMessagesRequest) Reset 

func (m *ListMessagesRequest) Reset()

func (*ListMessagesRequest) String 

func (m *ListMessagesRequest) String() string

func (*ListMessagesRequest) XXX_DiscardUnknown 

func (m *ListMessagesRequest) XXX_DiscardUnknown()

func (*ListMessagesRequest) XXX_Marshal 

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

func (*ListMessagesRequest) XXX_Merge 

func (m *ListMessagesRequest) XXX_Merge(src proto.Message)

func (*ListMessagesRequest) XXX_Size 

func (m *ListMessagesRequest) XXX_Size() int

func (*ListMessagesRequest) XXX_Unmarshal 

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

type ListMessagesResponse 

type ListMessagesResponse struct {
	Messages             []*Message `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*ListMessagesResponse) Descriptor 

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

func (*ListMessagesResponse) GetMessages 

func (m *ListMessagesResponse) GetMessages() []*Message

func (*ListMessagesResponse) ProtoMessage 

func (*ListMessagesResponse) ProtoMessage()

func (*ListMessagesResponse) Reset 

func (m *ListMessagesResponse) Reset()

func (*ListMessagesResponse) String 

func (m *ListMessagesResponse) String() string

func (*ListMessagesResponse) XXX_DiscardUnknown 

func (m *ListMessagesResponse) XXX_DiscardUnknown()

func (*ListMessagesResponse) XXX_Marshal 

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

func (*ListMessagesResponse) XXX_Merge 

func (m *ListMessagesResponse) XXX_Merge(src proto.Message)

func (*ListMessagesResponse) XXX_Size 

func (m *ListMessagesResponse) XXX_Size() int

func (*ListMessagesResponse) XXX_Unmarshal 

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

type Message 

type Message struct {
	Uuid                 string   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Kind                 int64    `protobuf:"varint,2,opt,name=kind,proto3" json:"kind,omitempty"`
	SendersName          string   `protobuf:"bytes,3,opt,name=senders_name,json=sendersName,proto3" json:"senders_name,omitempty"`
	Subject              string   `protobuf:"bytes,4,opt,name=subject,proto3" json:"subject,omitempty"`
	Body                 string   `protobuf:"bytes,5,opt,name=body,proto3" json:"body,omitempty"`
	CreateTime           string   `protobuf:"bytes,8,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Message) Descriptor 

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

func (*Message) GetBody 

func (m *Message) GetBody() string

func (*Message) GetCreateTime 

func (m *Message) GetCreateTime() string

func (*Message) GetKind 

func (m *Message) GetKind() int64

func (*Message) GetSendersName 

func (m *Message) GetSendersName() string

func (*Message) GetSubject 

func (m *Message) GetSubject() string

func (*Message) GetUuid 

func (m *Message) GetUuid() string

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) String 

func (m *Message) String() string

func (*Message) XXX_DiscardUnknown 

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal 

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

func (*Message) XXX_Merge 

func (m *Message) XXX_Merge(src proto.Message)

func (*Message) XXX_Size 

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal 

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

type MessageCommandServiceClient 

type MessageCommandServiceClient interface {
	CreateMessage(ctx context.Context, in *CreateMessageRequest, opts ...grpc.CallOption) (*Message, error)
}

MessageCommandServiceClient is the client API for MessageCommandService service.

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

func NewMessageCommandServiceClient 

func NewMessageCommandServiceClient(cc *grpc.ClientConn) MessageCommandServiceClient

type MessageCommandServiceServer 

type MessageCommandServiceServer interface {
	CreateMessage(context.Context, *CreateMessageRequest) (*Message, error)
}

MessageCommandServiceServer is the server API for MessageCommandService service.

type MessageQueryServiceClient 

type MessageQueryServiceClient interface {
	ListMessages(ctx context.Context, in *ListMessagesRequest, opts ...grpc.CallOption) (*ListMessagesResponse, error)
}

MessageQueryServiceClient is the client API for MessageQueryService service.

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

func NewMessageQueryServiceClient 

func NewMessageQueryServiceClient(cc *grpc.ClientConn) MessageQueryServiceClient

type MessageQueryServiceServer 

type MessageQueryServiceServer interface {
	ListMessages(context.Context, *ListMessagesRequest) (*ListMessagesResponse, error)
}

MessageQueryServiceServer is the server API for MessageQueryService service.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.