proto

package
v0.3.1 Latest Latest
Warning

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

Go to latest
Published: Apr 24, 2019 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ListRequest_Filter_Status_name = map[int32]string{
	0: "ALL",
	1: "DONE",
}
View Source
var ListRequest_Filter_Status_value = map[string]int32{
	"ALL":  0,
	"DONE": 1,
}
View Source
var Status_name = map[int32]string{
	0: "OK",
	1: "DONE",
	2: "HELD",
}
View Source
var Status_value = map[string]int32{
	"OK":   0,
	"DONE": 1,
	"HELD": 2,
}

Functions

func RegisterV1Server

func RegisterV1Server(s *grpc.Server, srv V1Server)

Types

type AcquireRequest

type AcquireRequest struct {
	// Owner identifier
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	// Resource name/identifier.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Custom namespace.
	Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// TTL the maximum life-span of the acquired resource (in seconds).
	Ttl uint32 `protobuf:"varint,4,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// Custom, optional metadata.
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*AcquireRequest) Descriptor

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

func (*AcquireRequest) GetMetadata

func (m *AcquireRequest) GetMetadata() map[string]string

func (*AcquireRequest) GetName

func (m *AcquireRequest) GetName() string

func (*AcquireRequest) GetNamespace

func (m *AcquireRequest) GetNamespace() string

func (*AcquireRequest) GetOwner

func (m *AcquireRequest) GetOwner() string

func (*AcquireRequest) GetTtl

func (m *AcquireRequest) GetTtl() uint32

func (*AcquireRequest) ProtoMessage

func (*AcquireRequest) ProtoMessage()

func (*AcquireRequest) Reset

func (m *AcquireRequest) Reset()

func (*AcquireRequest) String

func (m *AcquireRequest) String() string

func (*AcquireRequest) XXX_DiscardUnknown

func (m *AcquireRequest) XXX_DiscardUnknown()

func (*AcquireRequest) XXX_Marshal

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

func (*AcquireRequest) XXX_Merge

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

func (*AcquireRequest) XXX_Size

func (m *AcquireRequest) XXX_Size() int

func (*AcquireRequest) XXX_Unmarshal

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

type AcquireResponse

type AcquireResponse struct {
	Status               Status   `protobuf:"varint,1,opt,name=status,proto3,enum=blacksquaremedia.accord.Status" json:"status,omitempty"`
	Handle               *Handle  `protobuf:"bytes,2,opt,name=handle,proto3" json:"handle,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AcquireResponse) Descriptor

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

func (*AcquireResponse) GetHandle

func (m *AcquireResponse) GetHandle() *Handle

func (*AcquireResponse) GetStatus

func (m *AcquireResponse) GetStatus() Status

func (*AcquireResponse) ProtoMessage

func (*AcquireResponse) ProtoMessage()

func (*AcquireResponse) Reset

func (m *AcquireResponse) Reset()

func (*AcquireResponse) String

func (m *AcquireResponse) String() string

func (*AcquireResponse) XXX_DiscardUnknown

func (m *AcquireResponse) XXX_DiscardUnknown()

func (*AcquireResponse) XXX_Marshal

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

func (*AcquireResponse) XXX_Merge

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

func (*AcquireResponse) XXX_Size

func (m *AcquireResponse) XXX_Size() int

func (*AcquireResponse) XXX_Unmarshal

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

type DoneRequest

type DoneRequest struct {
	// Owner identifier.
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	// Handle identifier.
	HandleId []byte `protobuf:"bytes,2,opt,name=handle_id,json=handleId,proto3" json:"handle_id,omitempty"`
	// Optional metadata.
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*DoneRequest) Descriptor

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

func (*DoneRequest) GetHandleId

func (m *DoneRequest) GetHandleId() []byte

func (*DoneRequest) GetMetadata

func (m *DoneRequest) GetMetadata() map[string]string

func (*DoneRequest) GetOwner

func (m *DoneRequest) GetOwner() string

func (*DoneRequest) ProtoMessage

func (*DoneRequest) ProtoMessage()

func (*DoneRequest) Reset

func (m *DoneRequest) Reset()

func (*DoneRequest) String

func (m *DoneRequest) String() string

func (*DoneRequest) XXX_DiscardUnknown

func (m *DoneRequest) XXX_DiscardUnknown()

func (*DoneRequest) XXX_Marshal

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

func (*DoneRequest) XXX_Merge

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

func (*DoneRequest) XXX_Size

func (m *DoneRequest) XXX_Size() int

func (*DoneRequest) XXX_Unmarshal

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

type DoneResponse

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

func (*DoneResponse) Descriptor

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

func (*DoneResponse) ProtoMessage

func (*DoneResponse) ProtoMessage()

func (*DoneResponse) Reset

func (m *DoneResponse) Reset()

func (*DoneResponse) String

func (m *DoneResponse) String() string

func (*DoneResponse) XXX_DiscardUnknown

func (m *DoneResponse) XXX_DiscardUnknown()

func (*DoneResponse) XXX_Marshal

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

func (*DoneResponse) XXX_Merge

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

func (*DoneResponse) XXX_Size

func (m *DoneResponse) XXX_Size() int

func (*DoneResponse) XXX_Unmarshal

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

type Handle

type Handle struct {
	// Handle ID
	Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Resource name/identifier, unique within namespace.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Custom namespace.
	Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Expiration UNIX timestamp (millisecond precision)
	ExpTime int64 `protobuf:"varint,4,opt,name=exp_time,json=expTime,proto3" json:"exp_time,omitempty"`
	// Done at UNIX timestamp (millisecond precision)
	DoneTime int64 `protobuf:"varint,5,opt,name=done_time,json=doneTime,proto3" json:"done_time,omitempty"`
	// Describes the number of times this handle has been acquired.
	NumAcquired uint32 `protobuf:"varint,6,opt,name=num_acquired,json=numAcquired,proto3" json:"num_acquired,omitempty"`
	// Metadata.
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Handle

func (*Handle) Descriptor

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

func (*Handle) GetDoneTime

func (m *Handle) GetDoneTime() int64

func (*Handle) GetExpTime

func (m *Handle) GetExpTime() int64

func (*Handle) GetId

func (m *Handle) GetId() []byte

func (*Handle) GetMetadata

func (m *Handle) GetMetadata() map[string]string

func (*Handle) GetName

func (m *Handle) GetName() string

func (*Handle) GetNamespace

func (m *Handle) GetNamespace() string

func (*Handle) GetNumAcquired

func (m *Handle) GetNumAcquired() uint32

func (*Handle) ProtoMessage

func (*Handle) ProtoMessage()

func (*Handle) Reset

func (m *Handle) Reset()

func (*Handle) String

func (m *Handle) String() string

func (*Handle) XXX_DiscardUnknown

func (m *Handle) XXX_DiscardUnknown()

func (*Handle) XXX_Marshal

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

func (*Handle) XXX_Merge

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

func (*Handle) XXX_Size

func (m *Handle) XXX_Size() int

func (*Handle) XXX_Unmarshal

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

type ListRequest

type ListRequest struct {
	// Filter object
	Filter               *ListRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*ListRequest) Descriptor

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

func (*ListRequest) GetFilter

func (m *ListRequest) GetFilter() *ListRequest_Filter

func (*ListRequest) ProtoMessage

func (*ListRequest) ProtoMessage()

func (*ListRequest) Reset

func (m *ListRequest) Reset()

func (*ListRequest) String

func (m *ListRequest) String() string

func (*ListRequest) XXX_DiscardUnknown

func (m *ListRequest) XXX_DiscardUnknown()

func (*ListRequest) XXX_Marshal

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

func (*ListRequest) XXX_Merge

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

func (*ListRequest) XXX_Size

func (m *ListRequest) XXX_Size() int

func (*ListRequest) XXX_Unmarshal

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

type ListRequest_Filter

type ListRequest_Filter struct {
	// Namespace prefix.
	Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// Only certain status.
	Status ListRequest_Filter_Status `protobuf:"varint,2,opt,name=status,proto3,enum=blacksquaremedia.accord.ListRequest_Filter_Status" json:"status,omitempty"`
	// Filter by metadata.
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ListRequest_Filter) Descriptor

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

func (*ListRequest_Filter) GetMetadata

func (m *ListRequest_Filter) GetMetadata() map[string]string

func (*ListRequest_Filter) GetPrefix

func (m *ListRequest_Filter) GetPrefix() string

func (*ListRequest_Filter) GetStatus

func (*ListRequest_Filter) ProtoMessage

func (*ListRequest_Filter) ProtoMessage()

func (*ListRequest_Filter) Reset

func (m *ListRequest_Filter) Reset()

func (*ListRequest_Filter) String

func (m *ListRequest_Filter) String() string

func (*ListRequest_Filter) XXX_DiscardUnknown

func (m *ListRequest_Filter) XXX_DiscardUnknown()

func (*ListRequest_Filter) XXX_Marshal

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

func (*ListRequest_Filter) XXX_Merge

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

func (*ListRequest_Filter) XXX_Size

func (m *ListRequest_Filter) XXX_Size() int

func (*ListRequest_Filter) XXX_Unmarshal

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

type ListRequest_Filter_Status

type ListRequest_Filter_Status int32
const (
	ListRequest_Filter_ALL  ListRequest_Filter_Status = 0
	ListRequest_Filter_DONE ListRequest_Filter_Status = 1
)

func (ListRequest_Filter_Status) EnumDescriptor

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

func (ListRequest_Filter_Status) String

func (x ListRequest_Filter_Status) String() string

type RenewRequest

type RenewRequest struct {
	// Owner identifier.
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	// Handle identifier.
	HandleId []byte `protobuf:"bytes,2,opt,name=handle_id,json=handleId,proto3" json:"handle_id,omitempty"`
	// TTL the maximum life-span of the acquired resource (in seconds).
	Ttl uint32 `protobuf:"varint,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// Optional metadata.
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*RenewRequest) Descriptor

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

func (*RenewRequest) GetHandleId

func (m *RenewRequest) GetHandleId() []byte

func (*RenewRequest) GetMetadata

func (m *RenewRequest) GetMetadata() map[string]string

func (*RenewRequest) GetOwner

func (m *RenewRequest) GetOwner() string

func (*RenewRequest) GetTtl

func (m *RenewRequest) GetTtl() uint32

func (*RenewRequest) ProtoMessage

func (*RenewRequest) ProtoMessage()

func (*RenewRequest) Reset

func (m *RenewRequest) Reset()

func (*RenewRequest) String

func (m *RenewRequest) String() string

func (*RenewRequest) XXX_DiscardUnknown

func (m *RenewRequest) XXX_DiscardUnknown()

func (*RenewRequest) XXX_Marshal

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

func (*RenewRequest) XXX_Merge

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

func (*RenewRequest) XXX_Size

func (m *RenewRequest) XXX_Size() int

func (*RenewRequest) XXX_Unmarshal

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

type RenewResponse

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

func (*RenewResponse) Descriptor

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

func (*RenewResponse) ProtoMessage

func (*RenewResponse) ProtoMessage()

func (*RenewResponse) Reset

func (m *RenewResponse) Reset()

func (*RenewResponse) String

func (m *RenewResponse) String() string

func (*RenewResponse) XXX_DiscardUnknown

func (m *RenewResponse) XXX_DiscardUnknown()

func (*RenewResponse) XXX_Marshal

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

func (*RenewResponse) XXX_Merge

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

func (*RenewResponse) XXX_Size

func (m *RenewResponse) XXX_Size() int

func (*RenewResponse) XXX_Unmarshal

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

type Status

type Status int32
const (
	Status_OK   Status = 0
	Status_DONE Status = 1
	Status_HELD Status = 2
)

func (Status) EnumDescriptor

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

func (Status) String

func (x Status) String() string

type UnimplementedV1Server

type UnimplementedV1Server struct {
}

UnimplementedV1Server can be embedded to have forward compatible implementations.

func (*UnimplementedV1Server) Acquire

func (*UnimplementedV1Server) Done

func (*UnimplementedV1Server) List

func (*UnimplementedV1Server) Renew

type V1Client

type V1Client interface {
	// Acquire requests resource handle.
	Acquire(ctx context.Context, in *AcquireRequest, opts ...grpc.CallOption) (*AcquireResponse, error)
	// Renew renews resource handle.
	Renew(ctx context.Context, in *RenewRequest, opts ...grpc.CallOption) (*RenewResponse, error)
	// Done marks an handle as completed.
	Done(ctx context.Context, in *DoneRequest, opts ...grpc.CallOption) (*DoneResponse, error)
	// List streams handles that are done.
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (V1_ListClient, error)
}

V1Client is the client API for V1 service.

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

func NewV1Client

func NewV1Client(cc *grpc.ClientConn) V1Client

type V1Server

type V1Server interface {
	// Acquire requests resource handle.
	Acquire(context.Context, *AcquireRequest) (*AcquireResponse, error)
	// Renew renews resource handle.
	Renew(context.Context, *RenewRequest) (*RenewResponse, error)
	// Done marks an handle as completed.
	Done(context.Context, *DoneRequest) (*DoneResponse, error)
	// List streams handles that are done.
	List(*ListRequest, V1_ListServer) error
}

V1Server is the server API for V1 service.

type V1_ListClient

type V1_ListClient interface {
	Recv() (*Handle, error)
	grpc.ClientStream
}

type V1_ListServer

type V1_ListServer interface {
	Send(*Handle) error
	grpc.ServerStream
}

Jump to

Keyboard shortcuts

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