storage

Documentation

Overview

Package storage is a generated protocol buffer package.

It is generated from these files:

storage.proto

It has these top-level messages:

ProposeRequest
ProposeResponse
LookupRequest
LookupResponse

Package storage is a generated protocol buffer package.

It is generated from these files:

storage.proto

It has these top-level messages:

ProposeRequest
ProposeResponse
LookupRequest
LookupResponse

Index

• func RegisterStorageEndpointHandler(s server.Server, hdlr StorageEndpointHandler, opts ...server.HandlerOption)
• type LookupRequest
  • func (*LookupRequest) Descriptor() ([]byte, []int)
  • func (m *LookupRequest) GetKey() string
  • func (*LookupRequest) ProtoMessage()
  • func (m *LookupRequest) Reset()
  • func (m *LookupRequest) String() string
  • func (this *LookupRequest) Validate() error
• type LookupResponse
  • func (*LookupResponse) Descriptor() ([]byte, []int)
  • func (m *LookupResponse) GetValue() []byte
  • func (*LookupResponse) ProtoMessage()
  • func (m *LookupResponse) Reset()
  • func (m *LookupResponse) String() string
  • func (this *LookupResponse) Validate() error
• type ProposeRequest
  • func (*ProposeRequest) Descriptor() ([]byte, []int)
  • func (m *ProposeRequest) GetKey() string
  • func (m *ProposeRequest) GetValue() []byte
  • func (*ProposeRequest) ProtoMessage()
  • func (m *ProposeRequest) Reset()
  • func (m *ProposeRequest) String() string
  • func (this *ProposeRequest) Validate() error
• type ProposeResponse
  • func (*ProposeResponse) Descriptor() ([]byte, []int)
  • func (*ProposeResponse) ProtoMessage()
  • func (m *ProposeResponse) Reset()
  • func (m *ProposeResponse) String() string
  • func (this *ProposeResponse) Validate() error
• type StorageEndpoint
  • func (h *StorageEndpoint) Lookup(ctx context.Context, in *LookupRequest, out *LookupResponse) error
  • func (h *StorageEndpoint) Propose(ctx context.Context, in *ProposeRequest, out *ProposeResponse) error
• type StorageEndpointClient
  • func NewStorageEndpointClient(serviceName string, c client.Client) StorageEndpointClient
• type StorageEndpointHandler

Functions

func RegisterStorageEndpointHandler

func RegisterStorageEndpointHandler(s server.Server, hdlr StorageEndpointHandler, opts ...server.HandlerOption)

Types

type LookupRequest

type LookupRequest struct {
	Key string `protobuf:"bytes,1,opt,name=Key" json:"Key,omitempty"`
}

func (*LookupRequest) Descriptor

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

func (*LookupRequest) GetKey

func (m *LookupRequest) GetKey() string

func (*LookupRequest) ProtoMessage

func (*LookupRequest) ProtoMessage()

func (*LookupRequest) Reset

func (m *LookupRequest) Reset()

func (*LookupRequest) String

func (m *LookupRequest) String() string

func (*LookupRequest) Validate

func (this *LookupRequest) Validate() error

type LookupResponse

type LookupResponse struct {
	Value []byte `protobuf:"bytes,1,opt,name=Value,proto3" json:"Value,omitempty"`
}

func (*LookupResponse) Descriptor

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

func (*LookupResponse) GetValue

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

func (*LookupResponse) ProtoMessage

func (*LookupResponse) ProtoMessage()

func (*LookupResponse) Reset

func (m *LookupResponse) Reset()

func (*LookupResponse) String

func (m *LookupResponse) String() string

func (*LookupResponse) Validate

func (this *LookupResponse) Validate() error

type ProposeRequest

type ProposeRequest struct {
	Key   string `protobuf:"bytes,1,opt,name=Key" json:"Key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
}

func (*ProposeRequest) Descriptor

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

func (*ProposeRequest) GetKey

func (m *ProposeRequest) GetKey() string

func (*ProposeRequest) GetValue

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

func (*ProposeRequest) ProtoMessage

func (*ProposeRequest) ProtoMessage()

func (*ProposeRequest) Reset

func (m *ProposeRequest) Reset()

func (*ProposeRequest) String

func (m *ProposeRequest) String() string

func (*ProposeRequest) Validate

func (this *ProposeRequest) Validate() error

type ProposeResponse

type ProposeResponse struct {
}

func (*ProposeResponse) Descriptor

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

func (*ProposeResponse) ProtoMessage

func (*ProposeResponse) ProtoMessage()

func (*ProposeResponse) Reset

func (m *ProposeResponse) Reset()

func (*ProposeResponse) String

func (m *ProposeResponse) String() string

func (*ProposeResponse) Validate

func (this *ProposeResponse) Validate() error

type StorageEndpoint

type StorageEndpoint struct {
	StorageEndpointHandler
}

func (*StorageEndpoint) Lookup

func (h *StorageEndpoint) Lookup(ctx context.Context, in *LookupRequest, out *LookupResponse) error

func (*StorageEndpoint) Propose

func (h *StorageEndpoint) Propose(ctx context.Context, in *ProposeRequest, out *ProposeResponse) error

type StorageEndpointClient

type StorageEndpointClient interface {
	Propose(ctx context.Context, in *ProposeRequest, opts ...client.CallOption) (*ProposeResponse, error)
	Lookup(ctx context.Context, in *LookupRequest, opts ...client.CallOption) (*LookupResponse, error)
}

func NewStorageEndpointClient

func NewStorageEndpointClient(serviceName string, c client.Client) StorageEndpointClient

type StorageEndpointHandler

type StorageEndpointHandler interface {
	Propose(context.Context, *ProposeRequest, *ProposeResponse) error
	Lookup(context.Context, *LookupRequest, *LookupResponse) error
}