celestial

package
v0.0.0-...-b8642be Latest Latest
Warning

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

 Go to latest Published: Jul 1, 2020 License: MIT Imports: 8 Imported by: 10

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ReqKind_name = map[int32]string{
	0: "SECRETS",
	1: "CONFIGS",
	2: "ACTIONS",
	3: "NAMESPACES",
	4: "ROLES",
	5: "TOPOLOGY",
}
View Source 
var ReqKind_value = map[string]int32{
	"SECRETS":    0,
	"CONFIGS":    1,
	"ACTIONS":    2,
	"NAMESPACES": 3,
	"ROLES":      4,
	"TOPOLOGY":   5,
}

Functions

func RegisterCelestialServiceServer 

func RegisterCelestialServiceServer(s *grpc.Server, srv CelestialServiceServer)

Types

type CelestialServiceClient 

type CelestialServiceClient interface {
	List(ctx context.Context, in *ListReq, opts ...grpc.CallOption) (*ListResp, error)
	Mutate(ctx context.Context, in *MutateReq, opts ...grpc.CallOption) (*MutateResp, error)
}

CelestialServiceClient is the client API for CelestialService service.

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

func NewCelestialServiceClient 

func NewCelestialServiceClient(cc grpc.ClientConnInterface) CelestialServiceClient

type CelestialServiceServer 

type CelestialServiceServer interface {
	List(context.Context, *ListReq) (*ListResp, error)
	Mutate(context.Context, *MutateReq) (*MutateResp, error)
}

CelestialServiceServer is the server API for CelestialService service.

type Data 

type Data struct {
	Data                 map[string]string `` /* 149-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Data) Descriptor 

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

func (*Data) GetData 

func (m *Data) GetData() map[string]string

func (*Data) ProtoMessage 

func (*Data) ProtoMessage()

func (*Data) Reset 

func (m *Data) Reset()

func (*Data) String 

func (m *Data) String() string

func (*Data) XXX_DiscardUnknown 

func (m *Data) XXX_DiscardUnknown()

func (*Data) XXX_Marshal 

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

func (*Data) XXX_Merge 

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

func (*Data) XXX_Size 

func (m *Data) XXX_Size() int

func (*Data) XXX_Unmarshal 

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

type ListReq 

type ListReq struct {
	Kind                 ReqKind           `protobuf:"varint,1,opt,name=kind,proto3,enum=celestial.ReqKind" json:"kind,omitempty"`
	Extras               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

List messages

func (*ListReq) Descriptor 

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

func (*ListReq) GetExtras 

func (m *ListReq) GetExtras() map[string]string

func (*ListReq) GetKind 

func (m *ListReq) GetKind() ReqKind

func (*ListReq) ProtoMessage 

func (*ListReq) ProtoMessage()

func (*ListReq) Reset 

func (m *ListReq) Reset()

func (*ListReq) String 

func (m *ListReq) String() string

func (*ListReq) XXX_DiscardUnknown 

func (m *ListReq) XXX_DiscardUnknown()

func (*ListReq) XXX_Marshal 

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

func (*ListReq) XXX_Merge 

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

func (*ListReq) XXX_Size 

func (m *ListReq) XXX_Size() int

func (*ListReq) XXX_Unmarshal 

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

type ListResp 

type ListResp struct {
	RegionId             string            `protobuf:"bytes,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	ClusterId            string            `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	NodeId               string            `protobuf:"bytes,3,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Data                 []*Data           `protobuf:"bytes,4,rep,name=data,proto3" json:"data,omitempty"`
	Extras               map[string]string `` /* 153-byte string literal not displayed */
	Error                string            `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ListResp) Descriptor 

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

func (*ListResp) GetClusterId 

func (m *ListResp) GetClusterId() string

func (*ListResp) GetData 

func (m *ListResp) GetData() []*Data

func (*ListResp) GetError 

func (m *ListResp) GetError() string

func (*ListResp) GetExtras 

func (m *ListResp) GetExtras() map[string]string

func (*ListResp) GetNodeId 

func (m *ListResp) GetNodeId() string

func (*ListResp) GetRegionId 

func (m *ListResp) GetRegionId() string

func (*ListResp) ProtoMessage 

func (*ListResp) ProtoMessage()

func (*ListResp) Reset 

func (m *ListResp) Reset()

func (*ListResp) String 

func (m *ListResp) String() string

func (*ListResp) XXX_DiscardUnknown 

func (m *ListResp) XXX_DiscardUnknown()

func (*ListResp) XXX_Marshal 

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

func (*ListResp) XXX_Merge 

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

func (*ListResp) XXX_Size 

func (m *ListResp) XXX_Size() int

func (*ListResp) XXX_Unmarshal 

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

type MutateReq 

type MutateReq struct {
	Mutate               *core.Task `protobuf:"bytes,1,opt,name=mutate,proto3" json:"mutate,omitempty"`
	Index                []string   `protobuf:"bytes,2,rep,name=index,proto3" json:"index,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*MutateReq) Descriptor 

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

func (*MutateReq) GetIndex 

func (m *MutateReq) GetIndex() []string

func (*MutateReq) GetMutate 

func (m *MutateReq) GetMutate() *core.Task

func (*MutateReq) ProtoMessage 

func (*MutateReq) ProtoMessage()

func (*MutateReq) Reset 

func (m *MutateReq) Reset()

func (*MutateReq) String 

func (m *MutateReq) String() string

func (*MutateReq) XXX_DiscardUnknown 

func (m *MutateReq) XXX_DiscardUnknown()

func (*MutateReq) XXX_Marshal 

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

func (*MutateReq) XXX_Merge 

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

func (*MutateReq) XXX_Size 

func (m *MutateReq) XXX_Size() int

func (*MutateReq) XXX_Unmarshal 

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

type MutateResp 

type MutateResp struct {
	Error                string   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Mutate messages

func (*MutateResp) Descriptor 

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

func (*MutateResp) GetError 

func (m *MutateResp) GetError() string

func (*MutateResp) ProtoMessage 

func (*MutateResp) ProtoMessage()

func (*MutateResp) Reset 

func (m *MutateResp) Reset()

func (*MutateResp) String 

func (m *MutateResp) String() string

func (*MutateResp) XXX_DiscardUnknown 

func (m *MutateResp) XXX_DiscardUnknown()

func (*MutateResp) XXX_Marshal 

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

func (*MutateResp) XXX_Merge 

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

func (*MutateResp) XXX_Size 

func (m *MutateResp) XXX_Size() int

func (*MutateResp) XXX_Unmarshal 

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

type ReqKind 

type ReqKind int32

Enumerations 

const (
	ReqKind_SECRETS    ReqKind = 0
	ReqKind_CONFIGS    ReqKind = 1
	ReqKind_ACTIONS    ReqKind = 2
	ReqKind_NAMESPACES ReqKind = 3
	ReqKind_ROLES      ReqKind = 4
	ReqKind_TOPOLOGY   ReqKind = 5
)

func (ReqKind) EnumDescriptor 

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

func (ReqKind) String 

func (x ReqKind) String() string

type UnimplementedCelestialServiceServer 

type UnimplementedCelestialServiceServer struct {
}

UnimplementedCelestialServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedCelestialServiceServer) List 

func (*UnimplementedCelestialServiceServer) List(ctx context.Context, req *ListReq) (*ListResp, error)

func (*UnimplementedCelestialServiceServer) Mutate 

func (*UnimplementedCelestialServiceServer) Mutate(ctx context.Context, req *MutateReq) (*MutateResp, 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.