apiv1

package
v0.5.1 Latest Latest
Warning

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

 Go to latest Published: Jul 31, 2020 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterAPIServer 

func RegisterAPIServer(s *grpc.Server, srv APIServer)

Types

type APIClient 

type APIClient interface {
	// SetValues takes a list of key values and stores them in the datastore and
	// will notify subscribers of changes.
	SetValues(ctx context.Context, in *SetValuesRequest, opts ...grpc.CallOption) (*SetValuesResponse, error)
	// GetValues retrieves a list of key values.
	GetValues(ctx context.Context, in *GetValuesRequest, opts ...grpc.CallOption) (*GetValuesResponse, error)
	// Subscribe will subscribe to a key or prefix and return the current value
	// and any changes.
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (API_SubscribeClient, error)
}

APIClient is the client API for API service.

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

func NewAPIClient 

func NewAPIClient(cc grpc.ClientConnInterface) APIClient

type APIServer 

type APIServer interface {
	// SetValues takes a list of key values and stores them in the datastore and
	// will notify subscribers of changes.
	SetValues(context.Context, *SetValuesRequest) (*SetValuesResponse, error)
	// GetValues retrieves a list of key values.
	GetValues(context.Context, *GetValuesRequest) (*GetValuesResponse, error)
	// Subscribe will subscribe to a key or prefix and return the current value
	// and any changes.
	Subscribe(*SubscribeRequest, API_SubscribeServer) error
}

APIServer is the server API for API service.

type API_SubscribeClient 

type API_SubscribeClient interface {
	Recv() (*SubscribeResponse, error)
	grpc.ClientStream
}

type API_SubscribeServer 

type API_SubscribeServer interface {
	Send(*SubscribeResponse) error
	grpc.ServerStream
}

type GetValuesRequest 

type GetValuesRequest struct {
	Requests             []*GetValuesRequest_GetValue `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*GetValuesRequest) Descriptor 

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

func (*GetValuesRequest) GetRequests 

func (m *GetValuesRequest) GetRequests() []*GetValuesRequest_GetValue

func (*GetValuesRequest) ProtoMessage 

func (*GetValuesRequest) ProtoMessage()

func (*GetValuesRequest) Reset 

func (m *GetValuesRequest) Reset()

func (*GetValuesRequest) String 

func (m *GetValuesRequest) String() string

func (*GetValuesRequest) XXX_DiscardUnknown 

func (m *GetValuesRequest) XXX_DiscardUnknown()

func (*GetValuesRequest) XXX_Marshal 

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

func (*GetValuesRequest) XXX_Merge 

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

func (*GetValuesRequest) XXX_Size 

func (m *GetValuesRequest) XXX_Size() int

func (*GetValuesRequest) XXX_Unmarshal 

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

type GetValuesRequest_GetValue 

type GetValuesRequest_GetValue struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	IsPrefix             bool     `protobuf:"varint,2,opt,name=is_prefix,json=isPrefix,proto3" json:"is_prefix,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetValue is a get value request.

func (*GetValuesRequest_GetValue) Descriptor 

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

func (*GetValuesRequest_GetValue) GetIsPrefix 

func (m *GetValuesRequest_GetValue) GetIsPrefix() bool

func (*GetValuesRequest_GetValue) GetKey 

func (m *GetValuesRequest_GetValue) GetKey() string

func (*GetValuesRequest_GetValue) ProtoMessage 

func (*GetValuesRequest_GetValue) ProtoMessage()

func (*GetValuesRequest_GetValue) Reset 

func (m *GetValuesRequest_GetValue) Reset()

func (*GetValuesRequest_GetValue) String 

func (m *GetValuesRequest_GetValue) String() string

func (*GetValuesRequest_GetValue) XXX_DiscardUnknown 

func (m *GetValuesRequest_GetValue) XXX_DiscardUnknown()

func (*GetValuesRequest_GetValue) XXX_Marshal 

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

func (*GetValuesRequest_GetValue) XXX_Merge 

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

func (*GetValuesRequest_GetValue) XXX_Size 

func (m *GetValuesRequest_GetValue) XXX_Size() int

func (*GetValuesRequest_GetValue) XXX_Unmarshal 

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

type GetValuesResponse 

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

func (*GetValuesResponse) Descriptor 

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

func (*GetValuesResponse) GetMessages 

func (m *GetValuesResponse) GetMessages() []*KeyValue

func (*GetValuesResponse) ProtoMessage 

func (*GetValuesResponse) ProtoMessage()

func (*GetValuesResponse) Reset 

func (m *GetValuesResponse) Reset()

func (*GetValuesResponse) String 

func (m *GetValuesResponse) String() string

func (*GetValuesResponse) XXX_DiscardUnknown 

func (m *GetValuesResponse) XXX_DiscardUnknown()

func (*GetValuesResponse) XXX_Marshal 

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

func (*GetValuesResponse) XXX_Merge 

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

func (*GetValuesResponse) XXX_Size 

func (m *GetValuesResponse) XXX_Size() int

func (*GetValuesResponse) XXX_Unmarshal 

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

type KeyValue 

type KeyValue struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                []byte   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

KeyValue is a key value object.

func (*KeyValue) Descriptor 

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

func (*KeyValue) GetKey 

func (m *KeyValue) GetKey() string

func (*KeyValue) GetValue 

func (m *KeyValue) GetValue() []byte

func (*KeyValue) ProtoMessage 

func (*KeyValue) ProtoMessage()

func (*KeyValue) Reset 

func (m *KeyValue) Reset()

func (*KeyValue) String 

func (m *KeyValue) String() string

func (*KeyValue) XXX_DiscardUnknown 

func (m *KeyValue) XXX_DiscardUnknown()

func (*KeyValue) XXX_Marshal 

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

func (*KeyValue) XXX_Merge 

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

func (*KeyValue) XXX_Size 

func (m *KeyValue) XXX_Size() int

func (*KeyValue) XXX_Unmarshal 

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

type SetValuesRequest 

type SetValuesRequest struct {
	Messages             []*KeyValue        `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	TtlDuration          *duration.Duration `protobuf:"bytes,2,opt,name=ttl_duration,json=ttlDuration,proto3" json:"ttl_duration,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*SetValuesRequest) Descriptor 

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

func (*SetValuesRequest) GetMessages 

func (m *SetValuesRequest) GetMessages() []*KeyValue

func (*SetValuesRequest) GetTtlDuration added in v0.4.0 

func (m *SetValuesRequest) GetTtlDuration() *duration.Duration

func (*SetValuesRequest) ProtoMessage 

func (*SetValuesRequest) ProtoMessage()

func (*SetValuesRequest) Reset 

func (m *SetValuesRequest) Reset()

func (*SetValuesRequest) String 

func (m *SetValuesRequest) String() string

func (*SetValuesRequest) XXX_DiscardUnknown 

func (m *SetValuesRequest) XXX_DiscardUnknown()

func (*SetValuesRequest) XXX_Marshal 

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

func (*SetValuesRequest) XXX_Merge 

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

func (*SetValuesRequest) XXX_Size 

func (m *SetValuesRequest) XXX_Size() int

func (*SetValuesRequest) XXX_Unmarshal 

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

type SetValuesResponse 

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

func (*SetValuesResponse) Descriptor 

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

func (*SetValuesResponse) ProtoMessage 

func (*SetValuesResponse) ProtoMessage()

func (*SetValuesResponse) Reset 

func (m *SetValuesResponse) Reset()

func (*SetValuesResponse) String 

func (m *SetValuesResponse) String() string

func (*SetValuesResponse) XXX_DiscardUnknown 

func (m *SetValuesResponse) XXX_DiscardUnknown()

func (*SetValuesResponse) XXX_Marshal 

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

func (*SetValuesResponse) XXX_Merge 

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

func (*SetValuesResponse) XXX_Size 

func (m *SetValuesResponse) XXX_Size() int

func (*SetValuesResponse) XXX_Unmarshal 

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

type SubscribeRequest 

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

func (*SubscribeRequest) Descriptor 

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

func (*SubscribeRequest) GetPrefixes 

func (m *SubscribeRequest) GetPrefixes() []string

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) Reset 

func (m *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (m *SubscribeRequest) String() string

func (*SubscribeRequest) XXX_DiscardUnknown 

func (m *SubscribeRequest) XXX_DiscardUnknown()

func (*SubscribeRequest) XXX_Marshal 

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

func (*SubscribeRequest) XXX_Merge 

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

func (*SubscribeRequest) XXX_Size 

func (m *SubscribeRequest) XXX_Size() int

func (*SubscribeRequest) XXX_Unmarshal 

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

type SubscribeResponse 

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

func (*SubscribeResponse) Descriptor 

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

func (*SubscribeResponse) GetMessages 

func (m *SubscribeResponse) GetMessages() []*KeyValue

func (*SubscribeResponse) ProtoMessage 

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) Reset 

func (m *SubscribeResponse) Reset()

func (*SubscribeResponse) String 

func (m *SubscribeResponse) String() string

func (*SubscribeResponse) XXX_DiscardUnknown 

func (m *SubscribeResponse) XXX_DiscardUnknown()

func (*SubscribeResponse) XXX_Marshal 

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

func (*SubscribeResponse) XXX_Merge 

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

func (*SubscribeResponse) XXX_Size 

func (m *SubscribeResponse) XXX_Size() int

func (*SubscribeResponse) XXX_Unmarshal 

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

type UnimplementedAPIServer added in v0.4.0 

type UnimplementedAPIServer struct {
}

UnimplementedAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedAPIServer) GetValues added in v0.4.0 

func (*UnimplementedAPIServer) GetValues(ctx context.Context, req *GetValuesRequest) (*GetValuesResponse, error)

func (*UnimplementedAPIServer) SetValues added in v0.4.0 

func (*UnimplementedAPIServer) SetValues(ctx context.Context, req *SetValuesRequest) (*SetValuesResponse, error)

func (*UnimplementedAPIServer) Subscribe added in v0.4.0 

func (*UnimplementedAPIServer) Subscribe(req *SubscribeRequest, srv API_SubscribeServer) 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.