protocol

package
v0.0.0-...-e415e18 Latest Latest
Warning

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

 Go to latest Published: Feb 24, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var RequestResponse_StatusEnum_name = map[int32]string{
	0: "OK",
	1: "ERROR",
}
View Source 
var RequestResponse_StatusEnum_value = map[string]int32{
	"OK":    0,
	"ERROR": 1,
}

Functions

func InjectContactReaderClientInContext 

func InjectContactReaderClientInContext(ctx context.Context, cr ContactReaderClient) context.Context

InjectContactReaderClientInContext injects the contact reader client to the specified context

func InjectContactReaderServerInContext 

func InjectContactReaderServerInContext(ctx context.Context, cr ContactReaderServer) context.Context

InjectContactReaderServerInContext injects the contact reader client to the specified context

func InjectContactWriterClientInContext 

func InjectContactWriterClientInContext(ctx context.Context, cw ContactWriterClient) context.Context

InjectContactWriterClientInContext injects the contact writer client to the specified context

func InjectContactWriterServerInContext 

func InjectContactWriterServerInContext(ctx context.Context, cw ContactWriterServer) context.Context

InjectContactWriterServerInContext injects the contact writer client to the specified context

func RegisterContactReaderServer 

func RegisterContactReaderServer(s *grpc.Server, srv ContactReaderServer)

func RegisterContactWriterServer 

func RegisterContactWriterServer(s *grpc.Server, srv ContactWriterServer)

Types

type Contact 

type Contact struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string               `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	LastUpdated          *timestamp.Timestamp `protobuf:"bytes,5,opt,name=last_updated,json=lastUpdated,proto3" json:"last_updated,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Contact) Descriptor 

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

func (*Contact) GetId 

func (m *Contact) GetId() string

func (*Contact) GetLastUpdated 

func (m *Contact) GetLastUpdated() *timestamp.Timestamp

func (*Contact) GetName 

func (m *Contact) GetName() string

func (*Contact) ProtoMessage 

func (*Contact) ProtoMessage()

func (*Contact) Reset 

func (m *Contact) Reset()

func (*Contact) String 

func (m *Contact) String() string

func (*Contact) XXX_DiscardUnknown 

func (m *Contact) XXX_DiscardUnknown()

func (*Contact) XXX_Marshal 

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

func (*Contact) XXX_Merge 

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

func (*Contact) XXX_Size 

func (m *Contact) XXX_Size() int

func (*Contact) XXX_Unmarshal 

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

type ContactArrayRequestResponse 

type ContactArrayRequestResponse struct {
	Response             *RequestResponse `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	Contact              []*Contact       `protobuf:"bytes,2,rep,name=contact,proto3" json:"contact,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ContactArrayRequestResponse) Descriptor 

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

func (*ContactArrayRequestResponse) GetContact 

func (m *ContactArrayRequestResponse) GetContact() []*Contact

func (*ContactArrayRequestResponse) GetResponse 

func (m *ContactArrayRequestResponse) GetResponse() *RequestResponse

func (*ContactArrayRequestResponse) ProtoMessage 

func (*ContactArrayRequestResponse) ProtoMessage()

func (*ContactArrayRequestResponse) Reset 

func (m *ContactArrayRequestResponse) Reset()

func (*ContactArrayRequestResponse) String 

func (m *ContactArrayRequestResponse) String() string

func (*ContactArrayRequestResponse) XXX_DiscardUnknown 

func (m *ContactArrayRequestResponse) XXX_DiscardUnknown()

func (*ContactArrayRequestResponse) XXX_Marshal 

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

func (*ContactArrayRequestResponse) XXX_Merge 

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

func (*ContactArrayRequestResponse) XXX_Size 

func (m *ContactArrayRequestResponse) XXX_Size() int

func (*ContactArrayRequestResponse) XXX_Unmarshal 

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

type ContactReaderClient 

type ContactReaderClient interface {
	GetContact(ctx context.Context, in *ContactReference, opts ...grpc.CallOption) (*ContactRequestResponse, error)
	ListContacts(ctx context.Context, in *ListContactsFilter, opts ...grpc.CallOption) (*ContactArrayRequestResponse, error)
}

ContactReaderClient is the client API for ContactReader service.

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

func ContactReaderClientFromContext 

func ContactReaderClientFromContext(ctx context.Context) ContactReaderClient

ContactReaderFromContext returns a Contact Reader Client injected in Context

func NewContactReaderClient 

func NewContactReaderClient(cc *grpc.ClientConn) ContactReaderClient

type ContactReaderServer 

type ContactReaderServer interface {
	GetContact(context.Context, *ContactReference) (*ContactRequestResponse, error)
	ListContacts(context.Context, *ListContactsFilter) (*ContactArrayRequestResponse, error)
}

ContactReaderServer is the server API for ContactReader service.

func ContactReaderServerFromContext 

func ContactReaderServerFromContext(ctx context.Context) ContactReaderServer

ContactReaderFromContext returns a Contact Reader Server injected in Context

type ContactReference 

type ContactReference struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ContactReference) Descriptor 

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

func (*ContactReference) GetId 

func (m *ContactReference) GetId() string

func (*ContactReference) ProtoMessage 

func (*ContactReference) ProtoMessage()

func (*ContactReference) Reset 

func (m *ContactReference) Reset()

func (*ContactReference) String 

func (m *ContactReference) String() string

func (*ContactReference) XXX_DiscardUnknown 

func (m *ContactReference) XXX_DiscardUnknown()

func (*ContactReference) XXX_Marshal 

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

func (*ContactReference) XXX_Merge 

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

func (*ContactReference) XXX_Size 

func (m *ContactReference) XXX_Size() int

func (*ContactReference) XXX_Unmarshal 

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

type ContactRequestResponse 

type ContactRequestResponse struct {
	Response             *RequestResponse `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	Contact              *Contact         `protobuf:"bytes,2,opt,name=contact,proto3" json:"contact,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ContactRequestResponse) Descriptor 

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

func (*ContactRequestResponse) GetContact 

func (m *ContactRequestResponse) GetContact() *Contact

func (*ContactRequestResponse) GetResponse 

func (m *ContactRequestResponse) GetResponse() *RequestResponse

func (*ContactRequestResponse) ProtoMessage 

func (*ContactRequestResponse) ProtoMessage()

func (*ContactRequestResponse) Reset 

func (m *ContactRequestResponse) Reset()

func (*ContactRequestResponse) String 

func (m *ContactRequestResponse) String() string

func (*ContactRequestResponse) XXX_DiscardUnknown 

func (m *ContactRequestResponse) XXX_DiscardUnknown()

func (*ContactRequestResponse) XXX_Marshal 

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

func (*ContactRequestResponse) XXX_Merge 

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

func (*ContactRequestResponse) XXX_Size 

func (m *ContactRequestResponse) XXX_Size() int

func (*ContactRequestResponse) XXX_Unmarshal 

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

type ContactWriterClient 

type ContactWriterClient interface {
	AddContact(ctx context.Context, in *Contact, opts ...grpc.CallOption) (*RequestResponse, error)
	UpdateContact(ctx context.Context, in *Contact, opts ...grpc.CallOption) (*RequestResponse, error)
	DeleteContact(ctx context.Context, in *ContactReference, opts ...grpc.CallOption) (*RequestResponse, error)
}

ContactWriterClient is the client API for ContactWriter service.

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

func ContactWriterClientFromContext 

func ContactWriterClientFromContext(ctx context.Context) ContactWriterClient

ContactWriterClientFromContext returns a Contact Writer Client injected in Context

func NewContactWriterClient 

func NewContactWriterClient(cc *grpc.ClientConn) ContactWriterClient

type ContactWriterServer 

type ContactWriterServer interface {
	AddContact(context.Context, *Contact) (*RequestResponse, error)
	UpdateContact(context.Context, *Contact) (*RequestResponse, error)
	DeleteContact(context.Context, *ContactReference) (*RequestResponse, error)
}

ContactWriterServer is the server API for ContactWriter service.

func ContactWriterServerFromContext 

func ContactWriterServerFromContext(ctx context.Context) ContactWriterServer

ContactWriterServerFromContext returns a Contact Writer Server injected in Context

type ListContactsFilter 

type ListContactsFilter struct {
	Count                int32    `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListContactsFilter) Descriptor 

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

func (*ListContactsFilter) GetCount 

func (m *ListContactsFilter) GetCount() int32

func (*ListContactsFilter) ProtoMessage 

func (*ListContactsFilter) ProtoMessage()

func (*ListContactsFilter) Reset 

func (m *ListContactsFilter) Reset()

func (*ListContactsFilter) String 

func (m *ListContactsFilter) String() string

func (*ListContactsFilter) XXX_DiscardUnknown 

func (m *ListContactsFilter) XXX_DiscardUnknown()

func (*ListContactsFilter) XXX_Marshal 

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

func (*ListContactsFilter) XXX_Merge 

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

func (*ListContactsFilter) XXX_Size 

func (m *ListContactsFilter) XXX_Size() int

func (*ListContactsFilter) XXX_Unmarshal 

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

type RequestResponse 

type RequestResponse struct {
	Status               RequestResponse_StatusEnum `protobuf:"varint,1,opt,name=status,proto3,enum=protocol.RequestResponse_StatusEnum" json:"status,omitempty"`
	Message              string                     `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*RequestResponse) Descriptor 

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

func (*RequestResponse) GetMessage 

func (m *RequestResponse) GetMessage() string

func (*RequestResponse) GetStatus 

func (m *RequestResponse) GetStatus() RequestResponse_StatusEnum

func (*RequestResponse) ProtoMessage 

func (*RequestResponse) ProtoMessage()

func (*RequestResponse) Reset 

func (m *RequestResponse) Reset()

func (*RequestResponse) String 

func (m *RequestResponse) String() string

func (*RequestResponse) XXX_DiscardUnknown 

func (m *RequestResponse) XXX_DiscardUnknown()

func (*RequestResponse) XXX_Marshal 

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

func (*RequestResponse) XXX_Merge 

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

func (*RequestResponse) XXX_Size 

func (m *RequestResponse) XXX_Size() int

func (*RequestResponse) XXX_Unmarshal 

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

type RequestResponse_StatusEnum 

type RequestResponse_StatusEnum int32
const (
	RequestResponse_OK    RequestResponse_StatusEnum = 0
	RequestResponse_ERROR RequestResponse_StatusEnum = 1
)

func (RequestResponse_StatusEnum) EnumDescriptor 

func (RequestResponse_StatusEnum) EnumDescriptor() ([]byte, []int)

func (RequestResponse_StatusEnum) String 

func (x RequestResponse_StatusEnum) String() string

type UnimplementedContactReaderServer 

type UnimplementedContactReaderServer struct {
}

UnimplementedContactReaderServer can be embedded to have forward compatible implementations.

func (*UnimplementedContactReaderServer) GetContact 

func (*UnimplementedContactReaderServer) GetContact(ctx context.Context, req *ContactReference) (*ContactRequestResponse, error)

func (*UnimplementedContactReaderServer) ListContacts 

func (*UnimplementedContactReaderServer) ListContacts(ctx context.Context, req *ListContactsFilter) (*ContactArrayRequestResponse, error)

type UnimplementedContactWriterServer 

type UnimplementedContactWriterServer struct {
}

UnimplementedContactWriterServer can be embedded to have forward compatible implementations.

func (*UnimplementedContactWriterServer) AddContact 

func (*UnimplementedContactWriterServer) AddContact(ctx context.Context, req *Contact) (*RequestResponse, error)

func (*UnimplementedContactWriterServer) DeleteContact 

func (*UnimplementedContactWriterServer) DeleteContact(ctx context.Context, req *ContactReference) (*RequestResponse, error)

func (*UnimplementedContactWriterServer) UpdateContact 

func (*UnimplementedContactWriterServer) UpdateContact(ctx context.Context, req *Contact) (*RequestResponse, error)

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.