waste

package
v0.0.0-...-ab87cb8 Latest Latest
Warning

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

 Go to latest Published: Jul 10, 2019 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var State_name = map[int32]string{
	0: "RUNNING",
	1: "PENDING",
	2: "SUCCESS",
	3: "FAILURE",
	4: "APPROVAL",
}
View Source 
var State_value = map[string]int32{
	"RUNNING":  0,
	"PENDING":  1,
	"SUCCESS":  2,
	"FAILURE":  3,
	"APPROVAL": 4,
}

Functions

func RegisterWasteServer 

func RegisterWasteServer(s *grpc.Server, srv WasteServer)

Types

type Change 

type Change struct {
	Artifact             string    `protobuf:"bytes,1,opt,name=artifact,proto3" json:"artifact,omitempty"`
	Cluster              string    `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Db                   string    `protobuf:"bytes,3,opt,name=db,proto3" json:"db,omitempty"`
	Table                string    `protobuf:"bytes,4,opt,name=table,proto3" json:"table,omitempty"`
	Ddl                  string    `protobuf:"bytes,5,opt,name=ddl,proto3" json:"ddl,omitempty"`
	Leaders              []*Host   `protobuf:"bytes,6,rep,name=leaders,proto3" json:"leaders,omitempty"`
	Groups               []*GHosts `protobuf:"bytes,7,rep,name=groups,proto3" json:"groups,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Change) Descriptor 

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

func (*Change) GetArtifact 

func (m *Change) GetArtifact() string

func (*Change) GetCluster 

func (m *Change) GetCluster() string

func (*Change) GetDb 

func (m *Change) GetDb() string

func (*Change) GetDdl 

func (m *Change) GetDdl() string

func (*Change) GetGroups 

func (m *Change) GetGroups() []*GHosts

func (*Change) GetLeaders 

func (m *Change) GetLeaders() []*Host

func (*Change) GetTable 

func (m *Change) GetTable() string

func (*Change) ProtoMessage 

func (*Change) ProtoMessage()

func (*Change) Reset 

func (m *Change) Reset()

func (*Change) String 

func (m *Change) String() string

func (*Change) XXX_DiscardUnknown 

func (m *Change) XXX_DiscardUnknown()

func (*Change) XXX_Marshal 

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

func (*Change) XXX_Merge 

func (dst *Change) XXX_Merge(src proto.Message)

func (*Change) XXX_Size 

func (m *Change) XXX_Size() int

func (*Change) XXX_Unmarshal 

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

type ChangeStatus 

type ChangeStatus struct {
	ChangeState          State                `protobuf:"varint,1,opt,name=change_state,json=changeState,proto3,enum=waste.State" json:"change_state,omitempty"`
	Message              string               `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Uuid                 string               `protobuf:"bytes,3,opt,name=uuid,proto3" json:"uuid,omitempty"`
	ScheduledAt          *timestamp.Timestamp `protobuf:"bytes,4,opt,name=scheduled_at,json=scheduledAt,proto3" json:"scheduled_at,omitempty"`
	StartTime            *timestamp.Timestamp `protobuf:"bytes,5,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime              *timestamp.Timestamp `protobuf:"bytes,6,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Progress             int32                `protobuf:"varint,7,opt,name=progress,proto3" json:"progress,omitempty"`
	Eta                  *duration.Duration   `protobuf:"bytes,8,opt,name=eta,proto3" json:"eta,omitempty"`
	Change               *Change              `protobuf:"bytes,9,opt,name=change,proto3" json:"change,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ChangeStatus) Descriptor 

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

func (*ChangeStatus) GetChange 

func (m *ChangeStatus) GetChange() *Change

func (*ChangeStatus) GetChangeState 

func (m *ChangeStatus) GetChangeState() State

func (*ChangeStatus) GetEndTime 

func (m *ChangeStatus) GetEndTime() *timestamp.Timestamp

func (*ChangeStatus) GetEta 

func (m *ChangeStatus) GetEta() *duration.Duration

func (*ChangeStatus) GetMessage 

func (m *ChangeStatus) GetMessage() string

func (*ChangeStatus) GetProgress 

func (m *ChangeStatus) GetProgress() int32

func (*ChangeStatus) GetScheduledAt 

func (m *ChangeStatus) GetScheduledAt() *timestamp.Timestamp

func (*ChangeStatus) GetStartTime 

func (m *ChangeStatus) GetStartTime() *timestamp.Timestamp

func (*ChangeStatus) GetUuid 

func (m *ChangeStatus) GetUuid() string

func (*ChangeStatus) ProtoMessage 

func (*ChangeStatus) ProtoMessage()

func (*ChangeStatus) Reset 

func (m *ChangeStatus) Reset()

func (*ChangeStatus) String 

func (m *ChangeStatus) String() string

func (*ChangeStatus) XXX_DiscardUnknown 

func (m *ChangeStatus) XXX_DiscardUnknown()

func (*ChangeStatus) XXX_Marshal 

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

func (*ChangeStatus) XXX_Merge 

func (dst *ChangeStatus) XXX_Merge(src proto.Message)

func (*ChangeStatus) XXX_Size 

func (m *ChangeStatus) XXX_Size() int

func (*ChangeStatus) XXX_Unmarshal 

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

type Filter 

type Filter struct {
	Uuid                 []string `protobuf:"bytes,1,rep,name=uuid,proto3" json:"uuid,omitempty"`
	Artifact             []string `protobuf:"bytes,2,rep,name=artifact,proto3" json:"artifact,omitempty"`
	Cluster              []string `protobuf:"bytes,3,rep,name=cluster,proto3" json:"cluster,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Filter) Descriptor 

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

func (*Filter) GetArtifact 

func (m *Filter) GetArtifact() []string

func (*Filter) GetCluster 

func (m *Filter) GetCluster() []string

func (*Filter) GetUuid 

func (m *Filter) GetUuid() []string

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) Reset 

func (m *Filter) Reset()

func (*Filter) String 

func (m *Filter) String() string

func (*Filter) XXX_DiscardUnknown 

func (m *Filter) XXX_DiscardUnknown()

func (*Filter) XXX_Marshal 

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

func (*Filter) XXX_Merge 

func (dst *Filter) XXX_Merge(src proto.Message)

func (*Filter) XXX_Size 

func (m *Filter) XXX_Size() int

func (*Filter) XXX_Unmarshal 

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

type GHosts 

type GHosts struct {
	Leader               *Host    `protobuf:"bytes,1,opt,name=leader,proto3" json:"leader,omitempty"`
	Source               *Host    `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	Lagger               *Host    `protobuf:"bytes,3,opt,name=lagger,proto3" json:"lagger,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GHosts) Descriptor 

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

func (*GHosts) GetLagger 

func (m *GHosts) GetLagger() *Host

func (*GHosts) GetLeader 

func (m *GHosts) GetLeader() *Host

func (*GHosts) GetSource 

func (m *GHosts) GetSource() *Host

func (*GHosts) ProtoMessage 

func (*GHosts) ProtoMessage()

func (*GHosts) Reset 

func (m *GHosts) Reset()

func (*GHosts) String 

func (m *GHosts) String() string

func (*GHosts) XXX_DiscardUnknown 

func (m *GHosts) XXX_DiscardUnknown()

func (*GHosts) XXX_Marshal 

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

func (*GHosts) XXX_Merge 

func (dst *GHosts) XXX_Merge(src proto.Message)

func (*GHosts) XXX_Size 

func (m *GHosts) XXX_Size() int

func (*GHosts) XXX_Unmarshal 

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

type Host 

type Host struct {
	Hostname             string   `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Port                 int32    `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Host) Descriptor 

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

func (*Host) GetHostname 

func (m *Host) GetHostname() string

func (*Host) GetPort 

func (m *Host) GetPort() int32

func (*Host) ProtoMessage 

func (*Host) ProtoMessage()

func (*Host) Reset 

func (m *Host) Reset()

func (*Host) String 

func (m *Host) String() string

func (*Host) XXX_DiscardUnknown 

func (m *Host) XXX_DiscardUnknown()

func (*Host) XXX_Marshal 

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

func (*Host) XXX_Merge 

func (dst *Host) XXX_Merge(src proto.Message)

func (*Host) XXX_Size 

func (m *Host) XXX_Size() int

func (*Host) XXX_Unmarshal 

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

type State 

type State int32
const (
	State_RUNNING  State = 0
	State_PENDING  State = 1
	State_SUCCESS  State = 2
	State_FAILURE  State = 3
	State_APPROVAL State = 4
)

func (State) EnumDescriptor 

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

func (State) String 

func (x State) String() string

type WasteClient 

type WasteClient interface {
	Status(ctx context.Context, in *Filter, opts ...grpc.CallOption) (Waste_StatusClient, error)
	RunChange(ctx context.Context, in *Change, opts ...grpc.CallOption) (*ChangeStatus, error)
}

WasteClient is the client API for Waste service.

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

func NewWasteClient 

func NewWasteClient(cc *grpc.ClientConn) WasteClient

type WasteServer 

type WasteServer interface {
	Status(*Filter, Waste_StatusServer) error
	RunChange(context.Context, *Change) (*ChangeStatus, error)
}

WasteServer is the server API for Waste service.

type Waste_StatusClient 

type Waste_StatusClient interface {
	Recv() (*ChangeStatus, error)
	grpc.ClientStream
}

type Waste_StatusServer 

type Waste_StatusServer interface {
	Send(*ChangeStatus) error
	grpc.ServerStream
}

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.