apiv1

package
v0.6.3 Latest Latest
Warning

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

Go to latest
Published: Nov 10, 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) SetValues added in v0.4.0

func (*UnimplementedAPIServer) Subscribe added in v0.4.0

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL