go-micro: github.com/micro/go-micro/server/proto Index | Files

package go_micro_server

import "github.com/micro/go-micro/server/proto"

Index

Package Files

server.pb.go server.pb.micro.go

func RegisterServerHandler Uses

func RegisterServerHandler(s server.Server, hdlr ServerHandler, opts ...server.HandlerOption) error

type HandleRequest Uses

type HandleRequest struct {
    Service              string   `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
    Endpoint             string   `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
    Protocol             string   `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*HandleRequest) Descriptor Uses

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

func (*HandleRequest) GetEndpoint Uses

func (m *HandleRequest) GetEndpoint() string

func (*HandleRequest) GetProtocol Uses

func (m *HandleRequest) GetProtocol() string

func (*HandleRequest) GetService Uses

func (m *HandleRequest) GetService() string

func (*HandleRequest) ProtoMessage Uses

func (*HandleRequest) ProtoMessage()

func (*HandleRequest) Reset Uses

func (m *HandleRequest) Reset()

func (*HandleRequest) String Uses

func (m *HandleRequest) String() string

func (*HandleRequest) XXX_DiscardUnknown Uses

func (m *HandleRequest) XXX_DiscardUnknown()

func (*HandleRequest) XXX_Marshal Uses

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

func (*HandleRequest) XXX_Merge Uses

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

func (*HandleRequest) XXX_Size Uses

func (m *HandleRequest) XXX_Size() int

func (*HandleRequest) XXX_Unmarshal Uses

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

type HandleResponse Uses

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

func (*HandleResponse) Descriptor Uses

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

func (*HandleResponse) ProtoMessage Uses

func (*HandleResponse) ProtoMessage()

func (*HandleResponse) Reset Uses

func (m *HandleResponse) Reset()

func (*HandleResponse) String Uses

func (m *HandleResponse) String() string

func (*HandleResponse) XXX_DiscardUnknown Uses

func (m *HandleResponse) XXX_DiscardUnknown()

func (*HandleResponse) XXX_Marshal Uses

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

func (*HandleResponse) XXX_Merge Uses

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

func (*HandleResponse) XXX_Size Uses

func (m *HandleResponse) XXX_Size() int

func (*HandleResponse) XXX_Unmarshal Uses

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

type ServerHandler Uses

type ServerHandler interface {
    Handle(context.Context, *HandleRequest, *HandleResponse) error
    Subscribe(context.Context, *SubscribeRequest, *SubscribeResponse) error
}

type ServerService Uses

type ServerService interface {
    Handle(ctx context.Context, in *HandleRequest, opts ...client.CallOption) (*HandleResponse, error)
    Subscribe(ctx context.Context, in *SubscribeRequest, opts ...client.CallOption) (*SubscribeResponse, error)
}

func NewServerService Uses

func NewServerService(name string, c client.Client) ServerService

type SubscribeRequest Uses

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

func (*SubscribeRequest) Descriptor Uses

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

func (*SubscribeRequest) GetTopic Uses

func (m *SubscribeRequest) GetTopic() string

func (*SubscribeRequest) ProtoMessage Uses

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) Reset Uses

func (m *SubscribeRequest) Reset()

func (*SubscribeRequest) String Uses

func (m *SubscribeRequest) String() string

func (*SubscribeRequest) XXX_DiscardUnknown Uses

func (m *SubscribeRequest) XXX_DiscardUnknown()

func (*SubscribeRequest) XXX_Marshal Uses

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

func (*SubscribeRequest) XXX_Merge Uses

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

func (*SubscribeRequest) XXX_Size Uses

func (m *SubscribeRequest) XXX_Size() int

func (*SubscribeRequest) XXX_Unmarshal Uses

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

type SubscribeResponse Uses

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

func (*SubscribeResponse) Descriptor Uses

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

func (*SubscribeResponse) ProtoMessage Uses

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) Reset Uses

func (m *SubscribeResponse) Reset()

func (*SubscribeResponse) String Uses

func (m *SubscribeResponse) String() string

func (*SubscribeResponse) XXX_DiscardUnknown Uses

func (m *SubscribeResponse) XXX_DiscardUnknown()

func (*SubscribeResponse) XXX_Marshal Uses

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

func (*SubscribeResponse) XXX_Merge Uses

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

func (*SubscribeResponse) XXX_Size Uses

func (m *SubscribeResponse) XXX_Size() int

func (*SubscribeResponse) XXX_Unmarshal Uses

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

Package go_micro_server imports 6 packages (graph). Updated 2020-01-30. Refresh now. Tools for package owners.