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

package go_micro_router

import "github.com/micro/go-micro/router/service/proto"

Index

Package Files

router.pb.go router.pb.micro.go

Variables

var AdvertType_name = map[int32]string{
    0:  "AdvertAnnounce",
    1:  "AdvertUpdate",
}
var AdvertType_value = map[string]int32{
    "AdvertAnnounce": 0,
    "AdvertUpdate":   1,
}
var EventType_name = map[int32]string{
    0:  "Create",
    1:  "Delete",
    2:  "Update",
}
var EventType_value = map[string]int32{
    "Create": 0,
    "Delete": 1,
    "Update": 2,
}

func RegisterRouterHandler Uses

func RegisterRouterHandler(s server.Server, hdlr RouterHandler, opts ...server.HandlerOption) error

func RegisterTableHandler Uses

func RegisterTableHandler(s server.Server, hdlr TableHandler, opts ...server.HandlerOption) error
type Advert struct {
    // id of the advertising router
    Id  string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
    // type of advertisement
    Type AdvertType `protobuf:"varint,2,opt,name=type,proto3,enum=go.micro.router.AdvertType" json:"type,omitempty"`
    // unix timestamp of the advertisement
    Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
    // TTL of the Advert
    Ttl int64 `protobuf:"varint,4,opt,name=ttl,proto3" json:"ttl,omitempty"`
    // events is a list of advertised events
    Events               []*Event `protobuf:"bytes,5,rep,name=events,proto3" json:"events,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Advert is router advertsement streamed by Watch

func (*Advert) Descriptor Uses

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

func (*Advert) GetEvents Uses

func (m *Advert) GetEvents() []*Event

func (*Advert) GetId Uses

func (m *Advert) GetId() string

func (*Advert) GetTimestamp Uses

func (m *Advert) GetTimestamp() int64

func (*Advert) GetTtl Uses

func (m *Advert) GetTtl() int64

func (*Advert) GetType Uses

func (m *Advert) GetType() AdvertType

func (*Advert) ProtoMessage Uses

func (*Advert) ProtoMessage()

func (*Advert) Reset Uses

func (m *Advert) Reset()

func (*Advert) String Uses

func (m *Advert) String() string

func (*Advert) XXX_DiscardUnknown Uses

func (m *Advert) XXX_DiscardUnknown()

func (*Advert) XXX_Marshal Uses

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

func (*Advert) XXX_Merge Uses

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

func (*Advert) XXX_Size Uses

func (m *Advert) XXX_Size() int

func (*Advert) XXX_Unmarshal Uses

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

type AdvertType Uses

type AdvertType int32

AdvertType defines the type of advert

const (
    AdvertType_AdvertAnnounce AdvertType = 0
    AdvertType_AdvertUpdate   AdvertType = 1
)

func (AdvertType) EnumDescriptor Uses

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

func (AdvertType) String Uses

func (x AdvertType) String() string

type CreateResponse Uses

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

CreateResponse is returned by Create

func (*CreateResponse) Descriptor Uses

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

func (*CreateResponse) ProtoMessage Uses

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) Reset Uses

func (m *CreateResponse) Reset()

func (*CreateResponse) String Uses

func (m *CreateResponse) String() string

func (*CreateResponse) XXX_DiscardUnknown Uses

func (m *CreateResponse) XXX_DiscardUnknown()

func (*CreateResponse) XXX_Marshal Uses

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

func (*CreateResponse) XXX_Merge Uses

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

func (*CreateResponse) XXX_Size Uses

func (m *CreateResponse) XXX_Size() int

func (*CreateResponse) XXX_Unmarshal Uses

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

type DeleteResponse Uses

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

DeleteResponse is returned by Delete

func (*DeleteResponse) Descriptor Uses

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

func (*DeleteResponse) ProtoMessage Uses

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset Uses

func (m *DeleteResponse) Reset()

func (*DeleteResponse) String Uses

func (m *DeleteResponse) String() string

func (*DeleteResponse) XXX_DiscardUnknown Uses

func (m *DeleteResponse) XXX_DiscardUnknown()

func (*DeleteResponse) XXX_Marshal Uses

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

func (*DeleteResponse) XXX_Merge Uses

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

func (*DeleteResponse) XXX_Size Uses

func (m *DeleteResponse) XXX_Size() int

func (*DeleteResponse) XXX_Unmarshal Uses

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

type Event Uses

type Event struct {
    // the unique event id
    Id  string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
    // type of event
    Type EventType `protobuf:"varint,2,opt,name=type,proto3,enum=go.micro.router.EventType" json:"type,omitempty"`
    // unix timestamp of event
    Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
    // service route
    Route                *Route   `protobuf:"bytes,4,opt,name=route,proto3" json:"route,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Event is routing table event

func (*Event) Descriptor Uses

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

func (*Event) GetId Uses

func (m *Event) GetId() string

func (*Event) GetRoute Uses

func (m *Event) GetRoute() *Route

func (*Event) GetTimestamp Uses

func (m *Event) GetTimestamp() int64

func (*Event) GetType Uses

func (m *Event) GetType() EventType

func (*Event) ProtoMessage Uses

func (*Event) ProtoMessage()

func (*Event) Reset Uses

func (m *Event) Reset()

func (*Event) String Uses

func (m *Event) String() string

func (*Event) XXX_DiscardUnknown Uses

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal Uses

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

func (*Event) XXX_Merge Uses

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

func (*Event) XXX_Size Uses

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal Uses

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

type EventType Uses

type EventType int32

EventType defines the type of event

const (
    EventType_Create EventType = 0
    EventType_Delete EventType = 1
    EventType_Update EventType = 2
)

func (EventType) EnumDescriptor Uses

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

func (EventType) String Uses

func (x EventType) String() string

type ListResponse Uses

type ListResponse struct {
    Routes               []*Route `protobuf:"bytes,1,rep,name=routes,proto3" json:"routes,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

ListResponse is returned by List

func (*ListResponse) Descriptor Uses

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

func (*ListResponse) GetRoutes Uses

func (m *ListResponse) GetRoutes() []*Route

func (*ListResponse) ProtoMessage Uses

func (*ListResponse) ProtoMessage()

func (*ListResponse) Reset Uses

func (m *ListResponse) Reset()

func (*ListResponse) String Uses

func (m *ListResponse) String() string

func (*ListResponse) XXX_DiscardUnknown Uses

func (m *ListResponse) XXX_DiscardUnknown()

func (*ListResponse) XXX_Marshal Uses

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

func (*ListResponse) XXX_Merge Uses

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

func (*ListResponse) XXX_Size Uses

func (m *ListResponse) XXX_Size() int

func (*ListResponse) XXX_Unmarshal Uses

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

type LookupRequest Uses

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

LookupRequest is made to Lookup

func (*LookupRequest) Descriptor Uses

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

func (*LookupRequest) GetQuery Uses

func (m *LookupRequest) GetQuery() *Query

func (*LookupRequest) ProtoMessage Uses

func (*LookupRequest) ProtoMessage()

func (*LookupRequest) Reset Uses

func (m *LookupRequest) Reset()

func (*LookupRequest) String Uses

func (m *LookupRequest) String() string

func (*LookupRequest) XXX_DiscardUnknown Uses

func (m *LookupRequest) XXX_DiscardUnknown()

func (*LookupRequest) XXX_Marshal Uses

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

func (*LookupRequest) XXX_Merge Uses

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

func (*LookupRequest) XXX_Size Uses

func (m *LookupRequest) XXX_Size() int

func (*LookupRequest) XXX_Unmarshal Uses

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

type LookupResponse Uses

type LookupResponse struct {
    Routes               []*Route `protobuf:"bytes,1,rep,name=routes,proto3" json:"routes,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

LookupResponse is returned by Lookup

func (*LookupResponse) Descriptor Uses

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

func (*LookupResponse) GetRoutes Uses

func (m *LookupResponse) GetRoutes() []*Route

func (*LookupResponse) ProtoMessage Uses

func (*LookupResponse) ProtoMessage()

func (*LookupResponse) Reset Uses

func (m *LookupResponse) Reset()

func (*LookupResponse) String Uses

func (m *LookupResponse) String() string

func (*LookupResponse) XXX_DiscardUnknown Uses

func (m *LookupResponse) XXX_DiscardUnknown()

func (*LookupResponse) XXX_Marshal Uses

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

func (*LookupResponse) XXX_Merge Uses

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

func (*LookupResponse) XXX_Size Uses

func (m *LookupResponse) XXX_Size() int

func (*LookupResponse) XXX_Unmarshal Uses

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

type ProcessResponse Uses

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

ProcessResponse is returned by Process

func (*ProcessResponse) Descriptor Uses

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

func (*ProcessResponse) ProtoMessage Uses

func (*ProcessResponse) ProtoMessage()

func (*ProcessResponse) Reset Uses

func (m *ProcessResponse) Reset()

func (*ProcessResponse) String Uses

func (m *ProcessResponse) String() string

func (*ProcessResponse) XXX_DiscardUnknown Uses

func (m *ProcessResponse) XXX_DiscardUnknown()

func (*ProcessResponse) XXX_Marshal Uses

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

func (*ProcessResponse) XXX_Merge Uses

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

func (*ProcessResponse) XXX_Size Uses

func (m *ProcessResponse) XXX_Size() int

func (*ProcessResponse) XXX_Unmarshal Uses

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

type Query Uses

type Query struct {
    // service to lookup
    Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
    // gateway to lookup
    Gateway string `protobuf:"bytes,2,opt,name=gateway,proto3" json:"gateway,omitempty"`
    // network to lookup
    Network              string   `protobuf:"bytes,3,opt,name=network,proto3" json:"network,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Query is passed in a LookupRequest

func (*Query) Descriptor Uses

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

func (*Query) GetGateway Uses

func (m *Query) GetGateway() string

func (*Query) GetNetwork Uses

func (m *Query) GetNetwork() string

func (*Query) GetService Uses

func (m *Query) GetService() string

func (*Query) ProtoMessage Uses

func (*Query) ProtoMessage()

func (*Query) Reset Uses

func (m *Query) Reset()

func (*Query) String Uses

func (m *Query) String() string

func (*Query) XXX_DiscardUnknown Uses

func (m *Query) XXX_DiscardUnknown()

func (*Query) XXX_Marshal Uses

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

func (*Query) XXX_Merge Uses

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

func (*Query) XXX_Size Uses

func (m *Query) XXX_Size() int

func (*Query) XXX_Unmarshal Uses

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

type QueryRequest Uses

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

QueryRequest queries Table for Routes

func (*QueryRequest) Descriptor Uses

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

func (*QueryRequest) GetQuery Uses

func (m *QueryRequest) GetQuery() *Query

func (*QueryRequest) ProtoMessage Uses

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) Reset Uses

func (m *QueryRequest) Reset()

func (*QueryRequest) String Uses

func (m *QueryRequest) String() string

func (*QueryRequest) XXX_DiscardUnknown Uses

func (m *QueryRequest) XXX_DiscardUnknown()

func (*QueryRequest) XXX_Marshal Uses

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

func (*QueryRequest) XXX_Merge Uses

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

func (*QueryRequest) XXX_Size Uses

func (m *QueryRequest) XXX_Size() int

func (*QueryRequest) XXX_Unmarshal Uses

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

type QueryResponse Uses

type QueryResponse struct {
    Routes               []*Route `protobuf:"bytes,1,rep,name=routes,proto3" json:"routes,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

QueryResponse is returned by Query

func (*QueryResponse) Descriptor Uses

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

func (*QueryResponse) GetRoutes Uses

func (m *QueryResponse) GetRoutes() []*Route

func (*QueryResponse) ProtoMessage Uses

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) Reset Uses

func (m *QueryResponse) Reset()

func (*QueryResponse) String Uses

func (m *QueryResponse) String() string

func (*QueryResponse) XXX_DiscardUnknown Uses

func (m *QueryResponse) XXX_DiscardUnknown()

func (*QueryResponse) XXX_Marshal Uses

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

func (*QueryResponse) XXX_Merge Uses

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

func (*QueryResponse) XXX_Size Uses

func (m *QueryResponse) XXX_Size() int

func (*QueryResponse) XXX_Unmarshal Uses

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

type Request Uses

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

Empty request

func (*Request) Descriptor Uses

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

func (*Request) ProtoMessage Uses

func (*Request) ProtoMessage()

func (*Request) Reset Uses

func (m *Request) Reset()

func (*Request) String Uses

func (m *Request) String() string

func (*Request) XXX_DiscardUnknown Uses

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal Uses

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

func (*Request) XXX_Merge Uses

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

func (*Request) XXX_Size Uses

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal Uses

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

type Response Uses

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

Empty response

func (*Response) Descriptor Uses

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

func (*Response) ProtoMessage Uses

func (*Response) ProtoMessage()

func (*Response) Reset Uses

func (m *Response) Reset()

func (*Response) String Uses

func (m *Response) String() string

func (*Response) XXX_DiscardUnknown Uses

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal Uses

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

func (*Response) XXX_Merge Uses

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

func (*Response) XXX_Size Uses

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal Uses

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

type Route Uses

type Route struct {
    // service for the route
    Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
    // the address that advertise this route
    Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
    // gateway as the next hop
    Gateway string `protobuf:"bytes,3,opt,name=gateway,proto3" json:"gateway,omitempty"`
    // the network for this destination
    Network string `protobuf:"bytes,4,opt,name=network,proto3" json:"network,omitempty"`
    // router if the router id
    Router string `protobuf:"bytes,5,opt,name=router,proto3" json:"router,omitempty"`
    // the network link
    Link string `protobuf:"bytes,6,opt,name=link,proto3" json:"link,omitempty"`
    // the metric / score of this route
    Metric               int64    `protobuf:"varint,7,opt,name=metric,proto3" json:"metric,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Route is a service route

func (*Route) Descriptor Uses

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

func (*Route) GetAddress Uses

func (m *Route) GetAddress() string

func (*Route) GetGateway Uses

func (m *Route) GetGateway() string
func (m *Route) GetLink() string

func (*Route) GetMetric Uses

func (m *Route) GetMetric() int64

func (*Route) GetNetwork Uses

func (m *Route) GetNetwork() string

func (*Route) GetRouter Uses

func (m *Route) GetRouter() string

func (*Route) GetService Uses

func (m *Route) GetService() string

func (*Route) ProtoMessage Uses

func (*Route) ProtoMessage()

func (*Route) Reset Uses

func (m *Route) Reset()

func (*Route) String Uses

func (m *Route) String() string

func (*Route) XXX_DiscardUnknown Uses

func (m *Route) XXX_DiscardUnknown()

func (*Route) XXX_Marshal Uses

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

func (*Route) XXX_Merge Uses

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

func (*Route) XXX_Size Uses

func (m *Route) XXX_Size() int

func (*Route) XXX_Unmarshal Uses

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

type RouterHandler Uses

type RouterHandler interface {
    Lookup(context.Context, *LookupRequest, *LookupResponse) error
    Watch(context.Context, *WatchRequest, Router_WatchStream) error
    Advertise(context.Context, *Request, Router_AdvertiseStream) error
    Process(context.Context, *Advert, *ProcessResponse) error
}

type RouterService Uses

type RouterService interface {
    Lookup(ctx context.Context, in *LookupRequest, opts ...client.CallOption) (*LookupResponse, error)
    Watch(ctx context.Context, in *WatchRequest, opts ...client.CallOption) (Router_WatchService, error)
    Advertise(ctx context.Context, in *Request, opts ...client.CallOption) (Router_AdvertiseService, error)
    Process(ctx context.Context, in *Advert, opts ...client.CallOption) (*ProcessResponse, error)
}

func NewRouterService Uses

func NewRouterService(name string, c client.Client) RouterService

type Router_AdvertiseService Uses

type Router_AdvertiseService interface {
    SendMsg(interface{}) error
    RecvMsg(interface{}) error
    Close() error
    Recv() (*Advert, error)
}

type Router_AdvertiseStream Uses

type Router_AdvertiseStream interface {
    SendMsg(interface{}) error
    RecvMsg(interface{}) error
    Close() error
    Send(*Advert) error
}

type Router_WatchService Uses

type Router_WatchService interface {
    SendMsg(interface{}) error
    RecvMsg(interface{}) error
    Close() error
    Recv() (*Event, error)
}

type Router_WatchStream Uses

type Router_WatchStream interface {
    SendMsg(interface{}) error
    RecvMsg(interface{}) error
    Close() error
    Send(*Event) error
}

type TableHandler Uses

type TableHandler interface {
    Create(context.Context, *Route, *CreateResponse) error
    Delete(context.Context, *Route, *DeleteResponse) error
    Update(context.Context, *Route, *UpdateResponse) error
    List(context.Context, *Request, *ListResponse) error
    Query(context.Context, *QueryRequest, *QueryResponse) error
}

type TableService Uses

type TableService interface {
    Create(ctx context.Context, in *Route, opts ...client.CallOption) (*CreateResponse, error)
    Delete(ctx context.Context, in *Route, opts ...client.CallOption) (*DeleteResponse, error)
    Update(ctx context.Context, in *Route, opts ...client.CallOption) (*UpdateResponse, error)
    List(ctx context.Context, in *Request, opts ...client.CallOption) (*ListResponse, error)
    Query(ctx context.Context, in *QueryRequest, opts ...client.CallOption) (*QueryResponse, error)
}

func NewTableService Uses

func NewTableService(name string, c client.Client) TableService

type UpdateResponse Uses

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

UpdateResponse is returned by Update

func (*UpdateResponse) Descriptor Uses

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

func (*UpdateResponse) ProtoMessage Uses

func (*UpdateResponse) ProtoMessage()

func (*UpdateResponse) Reset Uses

func (m *UpdateResponse) Reset()

func (*UpdateResponse) String Uses

func (m *UpdateResponse) String() string

func (*UpdateResponse) XXX_DiscardUnknown Uses

func (m *UpdateResponse) XXX_DiscardUnknown()

func (*UpdateResponse) XXX_Marshal Uses

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

func (*UpdateResponse) XXX_Merge Uses

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

func (*UpdateResponse) XXX_Size Uses

func (m *UpdateResponse) XXX_Size() int

func (*UpdateResponse) XXX_Unmarshal Uses

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

type WatchRequest Uses

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

WatchRequest is made to Watch Router

func (*WatchRequest) Descriptor Uses

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

func (*WatchRequest) ProtoMessage Uses

func (*WatchRequest) ProtoMessage()

func (*WatchRequest) Reset Uses

func (m *WatchRequest) Reset()

func (*WatchRequest) String Uses

func (m *WatchRequest) String() string

func (*WatchRequest) XXX_DiscardUnknown Uses

func (m *WatchRequest) XXX_DiscardUnknown()

func (*WatchRequest) XXX_Marshal Uses

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

func (*WatchRequest) XXX_Merge Uses

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

func (*WatchRequest) XXX_Size Uses

func (m *WatchRequest) XXX_Size() int

func (*WatchRequest) XXX_Unmarshal Uses

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

Package go_micro_router imports 6 packages (graph) and is imported by 16 packages. Updated 2020-02-22. Refresh now. Tools for package owners.