api

package
v0.0.0-...-80f65e5 Latest Latest
Warning

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

 Go to latest Published: Dec 5, 2018 License: MIT Imports: 8 Imported by: 0

Documentation

Overview

Package api is a generated protocol buffer package.

It is generated from these files: 

api.proto

It has these top-level messages: 

FSMCommand
UpdateMetadataRequest
UpdateMetadataResponse
ExecuteCommandRequest
ExecuteCommandResponse
AddToClusterRequest
AddToClusterResponse

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowApi   = fmt.Errorf("proto: integer overflow")
)
View Source 
var CommandExecutionReply_name = map[int32]string{
	0: "NIL",
	1: "OK",
	2: "RAW_STRING",
	3: "STRING",
	4: "INT",
	5: "SLICE",
	6: "ERR",
}
View Source 
var CommandExecutionReply_value = map[string]int32{
	"NIL":        0,
	"OK":         1,
	"RAW_STRING": 2,
	"STRING":     3,
	"INT":        4,
	"SLICE":      5,
	"ERR":        6,
}
View Source 
var FSMCommandType_name = map[int32]string{
	0: "APPLY_COMMAND",
	1: "APPLY_METADATA",
}
View Source 
var FSMCommandType_value = map[string]int32{
	"APPLY_COMMAND":  0,
	"APPLY_METADATA": 1,
}

Functions

func RegisterGodownServer 

func RegisterGodownServer(s *grpc.Server, srv GodownServer)

Types

type AddToClusterRequest 

type AddToClusterRequest struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Addr string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
}

AddToClusterRequest is a request to add a new raft node to the cluster.

func (*AddToClusterRequest) Descriptor 

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

func (*AddToClusterRequest) GetAddr 

func (m *AddToClusterRequest) GetAddr() string

func (*AddToClusterRequest) GetId 

func (m *AddToClusterRequest) GetId() string

func (*AddToClusterRequest) Marshal 

func (m *AddToClusterRequest) Marshal() (dAtA []byte, err error)

func (*AddToClusterRequest) MarshalTo 

func (m *AddToClusterRequest) MarshalTo(dAtA []byte) (int, error)

func (*AddToClusterRequest) ProtoMessage 

func (*AddToClusterRequest) ProtoMessage()

func (*AddToClusterRequest) Reset 

func (m *AddToClusterRequest) Reset()

func (*AddToClusterRequest) Size 

func (m *AddToClusterRequest) Size() (n int)

func (*AddToClusterRequest) String 

func (m *AddToClusterRequest) String() string

func (*AddToClusterRequest) Unmarshal 

func (m *AddToClusterRequest) Unmarshal(dAtA []byte) error

type AddToClusterResponse 

type AddToClusterResponse struct {
}

AddToClusterResponse is a reponse on the AddToClusterRequest.

func (*AddToClusterResponse) Descriptor 

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

func (*AddToClusterResponse) Marshal 

func (m *AddToClusterResponse) Marshal() (dAtA []byte, err error)

func (*AddToClusterResponse) MarshalTo 

func (m *AddToClusterResponse) MarshalTo(dAtA []byte) (int, error)

func (*AddToClusterResponse) ProtoMessage 

func (*AddToClusterResponse) ProtoMessage()

func (*AddToClusterResponse) Reset 

func (m *AddToClusterResponse) Reset()

func (*AddToClusterResponse) Size 

func (m *AddToClusterResponse) Size() (n int)

func (*AddToClusterResponse) String 

func (m *AddToClusterResponse) String() string

func (*AddToClusterResponse) Unmarshal 

func (m *AddToClusterResponse) Unmarshal(dAtA []byte) error

type CommandExecutionReply 

type CommandExecutionReply int32

CommandExecutionReply describes all available replies. 

const (
	NilCommandReply       CommandExecutionReply = 0
	OkCommandReply        CommandExecutionReply = 1
	RawStringCommandReply CommandExecutionReply = 2
	StringCommandReply    CommandExecutionReply = 3
	IntCommandReply       CommandExecutionReply = 4
	SliceCommandReply     CommandExecutionReply = 5
	ErrCommandReply       CommandExecutionReply = 6
)

func (CommandExecutionReply) EnumDescriptor 

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

func (CommandExecutionReply) String 

func (x CommandExecutionReply) String() string

type ExecuteCommandRequest 

type ExecuteCommandRequest struct {
	Command string `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
}

ExecuteCommandRequest is a request to execute a command.

func (*ExecuteCommandRequest) Descriptor 

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

func (*ExecuteCommandRequest) GetCommand 

func (m *ExecuteCommandRequest) GetCommand() string

func (*ExecuteCommandRequest) Marshal 

func (m *ExecuteCommandRequest) Marshal() (dAtA []byte, err error)

func (*ExecuteCommandRequest) MarshalTo 

func (m *ExecuteCommandRequest) MarshalTo(dAtA []byte) (int, error)

func (*ExecuteCommandRequest) ProtoMessage 

func (*ExecuteCommandRequest) ProtoMessage()

func (*ExecuteCommandRequest) Reset 

func (m *ExecuteCommandRequest) Reset()

func (*ExecuteCommandRequest) Size 

func (m *ExecuteCommandRequest) Size() (n int)

func (*ExecuteCommandRequest) String 

func (m *ExecuteCommandRequest) String() string

func (*ExecuteCommandRequest) Unmarshal 

func (m *ExecuteCommandRequest) Unmarshal(dAtA []byte) error

type ExecuteCommandResponse 

type ExecuteCommandResponse struct {
	Reply CommandExecutionReply `protobuf:"varint,1,opt,name=reply,proto3,enum=CommandExecutionReply" json:"reply,omitempty"`
	Item  string                `protobuf:"bytes,2,opt,name=item,proto3" json:"item,omitempty"`
	Items []string              `protobuf:"bytes,3,rep,name=items" json:"items,omitempty"`
}

ExecuteCommandResponse is a response on the ExecuteCommandRequest.

func (*ExecuteCommandResponse) Descriptor 

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

func (*ExecuteCommandResponse) GetItem 

func (m *ExecuteCommandResponse) GetItem() string

func (*ExecuteCommandResponse) GetItems 

func (m *ExecuteCommandResponse) GetItems() []string

func (*ExecuteCommandResponse) GetReply 

func (m *ExecuteCommandResponse) GetReply() CommandExecutionReply

func (*ExecuteCommandResponse) Marshal 

func (m *ExecuteCommandResponse) Marshal() (dAtA []byte, err error)

func (*ExecuteCommandResponse) MarshalTo 

func (m *ExecuteCommandResponse) MarshalTo(dAtA []byte) (int, error)

func (*ExecuteCommandResponse) ProtoMessage 

func (*ExecuteCommandResponse) ProtoMessage()

func (*ExecuteCommandResponse) Reset 

func (m *ExecuteCommandResponse) Reset()

func (*ExecuteCommandResponse) Size 

func (m *ExecuteCommandResponse) Size() (n int)

func (*ExecuteCommandResponse) String 

func (m *ExecuteCommandResponse) String() string

func (*ExecuteCommandResponse) Unmarshal 

func (m *ExecuteCommandResponse) Unmarshal(dAtA []byte) error

type FSMCommand 

type FSMCommand struct {
	Type    FSMCommandType                                          `protobuf:"varint,1,opt,name=type,proto3,enum=FSMCommandType" json:"type,omitempty"`
	Command github_com_centrifugal_centrifugo_libcentrifugo_raw.Raw `protobuf:"bytes,2,opt,name=command,proto3,customtype=github.com/centrifugal/centrifugo/libcentrifugo/raw.Raw" json:"command"`
}

func (*FSMCommand) Descriptor 

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

func (*FSMCommand) GetType 

func (m *FSMCommand) GetType() FSMCommandType

func (*FSMCommand) Marshal 

func (m *FSMCommand) Marshal() (dAtA []byte, err error)

func (*FSMCommand) MarshalTo 

func (m *FSMCommand) MarshalTo(dAtA []byte) (int, error)

func (*FSMCommand) ProtoMessage 

func (*FSMCommand) ProtoMessage()

func (*FSMCommand) Reset 

func (m *FSMCommand) Reset()

func (*FSMCommand) Size 

func (m *FSMCommand) Size() (n int)

func (*FSMCommand) String 

func (m *FSMCommand) String() string

func (*FSMCommand) Unmarshal 

func (m *FSMCommand) Unmarshal(dAtA []byte) error

type FSMCommandType 

type FSMCommandType int32
const (
	FSMApplyCommand  FSMCommandType = 0
	FSMApplyMetadata FSMCommandType = 1
)

func (FSMCommandType) EnumDescriptor 

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

func (FSMCommandType) String 

func (x FSMCommandType) String() string

type GodownClient 

type GodownClient interface {
	ExecuteCommand(ctx context.Context, in *ExecuteCommandRequest, opts ...grpc.CallOption) (*ExecuteCommandResponse, error)
	AddToCluster(ctx context.Context, in *AddToClusterRequest, opts ...grpc.CallOption) (*AddToClusterResponse, error)
}

func NewGodownClient 

func NewGodownClient(cc *grpc.ClientConn) GodownClient

type GodownServer 

type GodownServer interface {
	ExecuteCommand(context.Context, *ExecuteCommandRequest) (*ExecuteCommandResponse, error)
	AddToCluster(context.Context, *AddToClusterRequest) (*AddToClusterResponse, error)
}

type UpdateMetadataRequest 

type UpdateMetadataRequest struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

UpdateMetadataRequest is used to update meta info in the raft FSM.

func (*UpdateMetadataRequest) Descriptor 

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

func (*UpdateMetadataRequest) GetKey 

func (m *UpdateMetadataRequest) GetKey() string

func (*UpdateMetadataRequest) GetValue 

func (m *UpdateMetadataRequest) GetValue() string

func (*UpdateMetadataRequest) Marshal 

func (m *UpdateMetadataRequest) Marshal() (dAtA []byte, err error)

func (*UpdateMetadataRequest) MarshalTo 

func (m *UpdateMetadataRequest) MarshalTo(dAtA []byte) (int, error)

func (*UpdateMetadataRequest) ProtoMessage 

func (*UpdateMetadataRequest) ProtoMessage()

func (*UpdateMetadataRequest) Reset 

func (m *UpdateMetadataRequest) Reset()

func (*UpdateMetadataRequest) Size 

func (m *UpdateMetadataRequest) Size() (n int)

func (*UpdateMetadataRequest) String 

func (m *UpdateMetadataRequest) String() string

func (*UpdateMetadataRequest) Unmarshal 

func (m *UpdateMetadataRequest) Unmarshal(dAtA []byte) error

type UpdateMetadataResponse 

type UpdateMetadataResponse struct {
}

UpdateMetadataResponse is a response on the UpdateMetadataRequest.

func (*UpdateMetadataResponse) Descriptor 

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

func (*UpdateMetadataResponse) Marshal 

func (m *UpdateMetadataResponse) Marshal() (dAtA []byte, err error)

func (*UpdateMetadataResponse) MarshalTo 

func (m *UpdateMetadataResponse) MarshalTo(dAtA []byte) (int, error)

func (*UpdateMetadataResponse) ProtoMessage 

func (*UpdateMetadataResponse) ProtoMessage()

func (*UpdateMetadataResponse) Reset 

func (m *UpdateMetadataResponse) Reset()

func (*UpdateMetadataResponse) Size 

func (m *UpdateMetadataResponse) Size() (n int)

func (*UpdateMetadataResponse) String 

func (m *UpdateMetadataResponse) String() string

func (*UpdateMetadataResponse) Unmarshal 

func (m *UpdateMetadataResponse) Unmarshal(dAtA []byte) error

Source Files

  • api.pb.go

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.