protos

package
v0.0.51 Latest Latest
Warning

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

 Go to latest Published: Sep 11, 2021 License: Apache-2.0 Imports: 11 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GithubEvent_Type_name = map[int32]string{
	0: "UNSET",
	1: "AUTH_RESPONSE",
	2: "INSTALL_CREATED",
	3: "INSTALL_UPDATED",
	4: "INSTALL_DELETED",
	5: "PULL_CREATED",
	6: "PULL_MERGED",
}
View Source 
var GithubEvent_Type_value = map[string]int32{
	"UNSET":           0,
	"AUTH_RESPONSE":   1,
	"INSTALL_CREATED": 2,
	"INSTALL_UPDATED": 3,
	"INSTALL_DELETED": 4,
	"PULL_CREATED":    5,
	"PULL_MERGED":     6,
}
View Source 
var PollGithubAuthResponse_Status_name = map[int32]string{
	0: "PENDING",
	1: "SUCCESS",
	2: "FAILED",
}
View Source 
var PollGithubAuthResponse_Status_value = map[string]int32{
	"PENDING": 0,
	"SUCCESS": 1,
	"FAILED":  2,
}

Functions

func RegisterGithubServerServer added in v0.0.41 

func RegisterGithubServerServer(s *grpc.Server, srv GithubServerServer)

func RegisterPlumberServerServer 

func RegisterPlumberServerServer(s *grpc.Server, srv PlumberServerServer)

Types

type AuthResponse added in v0.0.41 

type AuthResponse struct {
	Authorized           bool     `protobuf:"varint,1,opt,name=authorized,proto3" json:"authorized,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

AuthResponse is sent by github-service and received by plumber GithubServer.Connect()

func (*AuthResponse) Descriptor added in v0.0.41 

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

func (*AuthResponse) GetAuthorized added in v0.0.41 

func (m *AuthResponse) GetAuthorized() bool

func (*AuthResponse) GetMessage added in v0.0.41 

func (m *AuthResponse) GetMessage() string

func (*AuthResponse) ProtoMessage added in v0.0.41 

func (*AuthResponse) ProtoMessage()

func (*AuthResponse) Reset added in v0.0.41 

func (m *AuthResponse) Reset()

func (*AuthResponse) String added in v0.0.41 

func (m *AuthResponse) String() string

func (*AuthResponse) XXX_DiscardUnknown added in v0.0.41 

func (m *AuthResponse) XXX_DiscardUnknown()

func (*AuthResponse) XXX_Marshal added in v0.0.41 

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

func (*AuthResponse) XXX_Merge added in v0.0.41 

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

func (*AuthResponse) XXX_Size added in v0.0.41 

func (m *AuthResponse) XXX_Size() int

func (*AuthResponse) XXX_Unmarshal added in v0.0.41 

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

type ConnectAuthRequest added in v0.0.41 

type ConnectAuthRequest struct {
	// Batch API token
	ApiToken string `protobuf:"bytes,1,opt,name=api_token,json=apiToken,proto3" json:"api_token,omitempty"`
	// Plumber Cluster ID
	ClusterId            string   `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Sent by plumber, received by github-service

func (*ConnectAuthRequest) Descriptor added in v0.0.41 

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

func (*ConnectAuthRequest) GetApiToken added in v0.0.41 

func (m *ConnectAuthRequest) GetApiToken() string

func (*ConnectAuthRequest) GetClusterId added in v0.0.41 

func (m *ConnectAuthRequest) GetClusterId() string

func (*ConnectAuthRequest) ProtoMessage added in v0.0.41 

func (*ConnectAuthRequest) ProtoMessage()

func (*ConnectAuthRequest) Reset added in v0.0.41 

func (m *ConnectAuthRequest) Reset()

func (*ConnectAuthRequest) String added in v0.0.41 

func (m *ConnectAuthRequest) String() string

func (*ConnectAuthRequest) XXX_DiscardUnknown added in v0.0.41 

func (m *ConnectAuthRequest) XXX_DiscardUnknown()

func (*ConnectAuthRequest) XXX_Marshal added in v0.0.41 

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

func (*ConnectAuthRequest) XXX_Merge added in v0.0.41 

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

func (*ConnectAuthRequest) XXX_Size added in v0.0.41 

func (m *ConnectAuthRequest) XXX_Size() int

func (*ConnectAuthRequest) XXX_Unmarshal added in v0.0.41 

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

type CreateConnectionRequest 

type CreateConnectionRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth            `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	Options              *opts.ConnectionOptions `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*CreateConnectionRequest) Descriptor 

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

func (*CreateConnectionRequest) GetAuth 

func (m *CreateConnectionRequest) GetAuth() *common.Auth

func (*CreateConnectionRequest) GetOptions added in v0.0.49 

func (m *CreateConnectionRequest) GetOptions() *opts.ConnectionOptions

func (*CreateConnectionRequest) ProtoMessage 

func (*CreateConnectionRequest) ProtoMessage()

func (*CreateConnectionRequest) Reset 

func (m *CreateConnectionRequest) Reset()

func (*CreateConnectionRequest) String 

func (m *CreateConnectionRequest) String() string

func (*CreateConnectionRequest) XXX_DiscardUnknown 

func (m *CreateConnectionRequest) XXX_DiscardUnknown()

func (*CreateConnectionRequest) XXX_Marshal 

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

func (*CreateConnectionRequest) XXX_Merge 

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

func (*CreateConnectionRequest) XXX_Size 

func (m *CreateConnectionRequest) XXX_Size() int

func (*CreateConnectionRequest) XXX_Unmarshal 

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

type CreateConnectionResponse 

type CreateConnectionResponse struct {
	// Set with uuid that represents connection if create is successful
	ConnectionId         string   `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateConnectionResponse) Descriptor 

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

func (*CreateConnectionResponse) GetConnectionId 

func (m *CreateConnectionResponse) GetConnectionId() string

func (*CreateConnectionResponse) ProtoMessage 

func (*CreateConnectionResponse) ProtoMessage()

func (*CreateConnectionResponse) Reset 

func (m *CreateConnectionResponse) Reset()

func (*CreateConnectionResponse) String 

func (m *CreateConnectionResponse) String() string

func (*CreateConnectionResponse) XXX_DiscardUnknown 

func (m *CreateConnectionResponse) XXX_DiscardUnknown()

func (*CreateConnectionResponse) XXX_Marshal 

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

func (*CreateConnectionResponse) XXX_Merge 

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

func (*CreateConnectionResponse) XXX_Size 

func (m *CreateConnectionResponse) XXX_Size() int

func (*CreateConnectionResponse) XXX_Unmarshal 

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

type CreateReadRequest added in v0.0.20 

type CreateReadRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth      `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	Read                 *opts.ReadOptions `protobuf:"bytes,1,opt,name=read,proto3" json:"read,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*CreateReadRequest) Descriptor added in v0.0.20 

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

func (*CreateReadRequest) GetAuth added in v0.0.20 

func (m *CreateReadRequest) GetAuth() *common.Auth

func (*CreateReadRequest) GetRead added in v0.0.20 

func (m *CreateReadRequest) GetRead() *opts.ReadOptions

func (*CreateReadRequest) ProtoMessage added in v0.0.20 

func (*CreateReadRequest) ProtoMessage()

func (*CreateReadRequest) Reset added in v0.0.20 

func (m *CreateReadRequest) Reset()

func (*CreateReadRequest) String added in v0.0.20 

func (m *CreateReadRequest) String() string

func (*CreateReadRequest) XXX_DiscardUnknown added in v0.0.20 

func (m *CreateReadRequest) XXX_DiscardUnknown()

func (*CreateReadRequest) XXX_Marshal added in v0.0.20 

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

func (*CreateReadRequest) XXX_Merge added in v0.0.20 

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

func (*CreateReadRequest) XXX_Size added in v0.0.20 

func (m *CreateReadRequest) XXX_Size() int

func (*CreateReadRequest) XXX_Unmarshal added in v0.0.20 

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

type CreateReadResponse added in v0.0.20 

type CreateReadResponse struct {
	Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	// Assigned and returned by plumber-server to identify a successful read request
	ReadId               string   `protobuf:"bytes,1,opt,name=read_id,json=readId,proto3" json:"read_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateReadResponse) Descriptor added in v0.0.20 

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

func (*CreateReadResponse) GetReadId added in v0.0.20 

func (m *CreateReadResponse) GetReadId() string

func (*CreateReadResponse) GetStatus added in v0.0.20 

func (m *CreateReadResponse) GetStatus() *common.Status

func (*CreateReadResponse) ProtoMessage added in v0.0.20 

func (*CreateReadResponse) ProtoMessage()

func (*CreateReadResponse) Reset added in v0.0.20 

func (m *CreateReadResponse) Reset()

func (*CreateReadResponse) String added in v0.0.20 

func (m *CreateReadResponse) String() string

func (*CreateReadResponse) XXX_DiscardUnknown added in v0.0.20 

func (m *CreateReadResponse) XXX_DiscardUnknown()

func (*CreateReadResponse) XXX_Marshal added in v0.0.20 

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

func (*CreateReadResponse) XXX_Merge added in v0.0.20 

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

func (*CreateReadResponse) XXX_Size added in v0.0.20 

func (m *CreateReadResponse) XXX_Size() int

func (*CreateReadResponse) XXX_Unmarshal added in v0.0.20 

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

type CreateRelayRequest 

type CreateRelayRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth       `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	Opts                 *opts.RelayOptions `protobuf:"bytes,1,opt,name=opts,proto3" json:"opts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*CreateRelayRequest) Descriptor 

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

func (*CreateRelayRequest) GetAuth 

func (m *CreateRelayRequest) GetAuth() *common.Auth

func (*CreateRelayRequest) GetOpts added in v0.0.49 

func (m *CreateRelayRequest) GetOpts() *opts.RelayOptions

func (*CreateRelayRequest) ProtoMessage 

func (*CreateRelayRequest) ProtoMessage()

func (*CreateRelayRequest) Reset 

func (m *CreateRelayRequest) Reset()

func (*CreateRelayRequest) String 

func (m *CreateRelayRequest) String() string

func (*CreateRelayRequest) XXX_DiscardUnknown 

func (m *CreateRelayRequest) XXX_DiscardUnknown()

func (*CreateRelayRequest) XXX_Marshal 

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

func (*CreateRelayRequest) XXX_Merge 

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

func (*CreateRelayRequest) XXX_Size 

func (m *CreateRelayRequest) XXX_Size() int

func (*CreateRelayRequest) XXX_Unmarshal 

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

type CreateRelayResponse 

type CreateRelayResponse struct {
	Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	// ID of the created relay entry
	RelayId              string   `protobuf:"bytes,1,opt,name=relay_id,json=relayId,proto3" json:"relay_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateRelayResponse) Descriptor 

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

func (*CreateRelayResponse) GetRelayId 

func (m *CreateRelayResponse) GetRelayId() string

func (*CreateRelayResponse) GetStatus 

func (m *CreateRelayResponse) GetStatus() *common.Status

func (*CreateRelayResponse) ProtoMessage 

func (*CreateRelayResponse) ProtoMessage()

func (*CreateRelayResponse) Reset 

func (m *CreateRelayResponse) Reset()

func (*CreateRelayResponse) String 

func (m *CreateRelayResponse) String() string

func (*CreateRelayResponse) XXX_DiscardUnknown 

func (m *CreateRelayResponse) XXX_DiscardUnknown()

func (*CreateRelayResponse) XXX_Marshal 

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

func (*CreateRelayResponse) XXX_Merge 

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

func (*CreateRelayResponse) XXX_Size 

func (m *CreateRelayResponse) XXX_Size() int

func (*CreateRelayResponse) XXX_Unmarshal 

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

type CreateServiceRequest added in v0.0.27 

type CreateServiceRequest struct {
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	Service              *Service     `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*CreateServiceRequest) Descriptor added in v0.0.27 

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

func (*CreateServiceRequest) GetAuth added in v0.0.27 

func (m *CreateServiceRequest) GetAuth() *common.Auth

func (*CreateServiceRequest) GetService added in v0.0.27 

func (m *CreateServiceRequest) GetService() *Service

func (*CreateServiceRequest) ProtoMessage added in v0.0.27 

func (*CreateServiceRequest) ProtoMessage()

func (*CreateServiceRequest) Reset added in v0.0.27 

func (m *CreateServiceRequest) Reset()

func (*CreateServiceRequest) String added in v0.0.27 

func (m *CreateServiceRequest) String() string

func (*CreateServiceRequest) XXX_DiscardUnknown added in v0.0.27 

func (m *CreateServiceRequest) XXX_DiscardUnknown()

func (*CreateServiceRequest) XXX_Marshal added in v0.0.27 

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

func (*CreateServiceRequest) XXX_Merge added in v0.0.27 

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

func (*CreateServiceRequest) XXX_Size added in v0.0.27 

func (m *CreateServiceRequest) XXX_Size() int

func (*CreateServiceRequest) XXX_Unmarshal added in v0.0.27 

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

type CreateServiceResponse added in v0.0.27 

type CreateServiceResponse struct {
	Service              *Service       `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*CreateServiceResponse) Descriptor added in v0.0.27 

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

func (*CreateServiceResponse) GetService added in v0.0.27 

func (m *CreateServiceResponse) GetService() *Service

func (*CreateServiceResponse) GetStatus added in v0.0.27 

func (m *CreateServiceResponse) GetStatus() *common.Status

func (*CreateServiceResponse) ProtoMessage added in v0.0.27 

func (*CreateServiceResponse) ProtoMessage()

func (*CreateServiceResponse) Reset added in v0.0.27 

func (m *CreateServiceResponse) Reset()

func (*CreateServiceResponse) String added in v0.0.27 

func (m *CreateServiceResponse) String() string

func (*CreateServiceResponse) XXX_DiscardUnknown added in v0.0.27 

func (m *CreateServiceResponse) XXX_DiscardUnknown()

func (*CreateServiceResponse) XXX_Marshal added in v0.0.27 

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

func (*CreateServiceResponse) XXX_Merge added in v0.0.27 

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

func (*CreateServiceResponse) XXX_Size added in v0.0.27 

func (m *CreateServiceResponse) XXX_Size() int

func (*CreateServiceResponse) XXX_Unmarshal added in v0.0.27 

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

type DeleteConnectionRequest 

type DeleteConnectionRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	ConnectionId         string       `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*DeleteConnectionRequest) Descriptor 

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

func (*DeleteConnectionRequest) GetAuth 

func (m *DeleteConnectionRequest) GetAuth() *common.Auth

func (*DeleteConnectionRequest) GetConnectionId 

func (m *DeleteConnectionRequest) GetConnectionId() string

func (*DeleteConnectionRequest) ProtoMessage 

func (*DeleteConnectionRequest) ProtoMessage()

func (*DeleteConnectionRequest) Reset 

func (m *DeleteConnectionRequest) Reset()

func (*DeleteConnectionRequest) String 

func (m *DeleteConnectionRequest) String() string

func (*DeleteConnectionRequest) XXX_DiscardUnknown 

func (m *DeleteConnectionRequest) XXX_DiscardUnknown()

func (*DeleteConnectionRequest) XXX_Marshal 

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

func (*DeleteConnectionRequest) XXX_Merge 

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

func (*DeleteConnectionRequest) XXX_Size 

func (m *DeleteConnectionRequest) XXX_Size() int

func (*DeleteConnectionRequest) XXX_Unmarshal 

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

type DeleteConnectionResponse 

type DeleteConnectionResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*DeleteConnectionResponse) Descriptor 

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

func (*DeleteConnectionResponse) GetStatus 

func (m *DeleteConnectionResponse) GetStatus() *common.Status

func (*DeleteConnectionResponse) ProtoMessage 

func (*DeleteConnectionResponse) ProtoMessage()

func (*DeleteConnectionResponse) Reset 

func (m *DeleteConnectionResponse) Reset()

func (*DeleteConnectionResponse) String 

func (m *DeleteConnectionResponse) String() string

func (*DeleteConnectionResponse) XXX_DiscardUnknown 

func (m *DeleteConnectionResponse) XXX_DiscardUnknown()

func (*DeleteConnectionResponse) XXX_Marshal 

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

func (*DeleteConnectionResponse) XXX_Merge 

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

func (*DeleteConnectionResponse) XXX_Size 

func (m *DeleteConnectionResponse) XXX_Size() int

func (*DeleteConnectionResponse) XXX_Unmarshal 

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

type DeleteReadRequest added in v0.0.20 

type DeleteReadRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	ReadId               string       `protobuf:"bytes,1,opt,name=read_id,json=readId,proto3" json:"read_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*DeleteReadRequest) Descriptor added in v0.0.20 

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

func (*DeleteReadRequest) GetAuth added in v0.0.20 

func (m *DeleteReadRequest) GetAuth() *common.Auth

func (*DeleteReadRequest) GetReadId added in v0.0.20 

func (m *DeleteReadRequest) GetReadId() string

func (*DeleteReadRequest) ProtoMessage added in v0.0.20 

func (*DeleteReadRequest) ProtoMessage()

func (*DeleteReadRequest) Reset added in v0.0.20 

func (m *DeleteReadRequest) Reset()

func (*DeleteReadRequest) String added in v0.0.20 

func (m *DeleteReadRequest) String() string

func (*DeleteReadRequest) XXX_DiscardUnknown added in v0.0.20 

func (m *DeleteReadRequest) XXX_DiscardUnknown()

func (*DeleteReadRequest) XXX_Marshal added in v0.0.20 

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

func (*DeleteReadRequest) XXX_Merge added in v0.0.20 

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

func (*DeleteReadRequest) XXX_Size added in v0.0.20 

func (m *DeleteReadRequest) XXX_Size() int

func (*DeleteReadRequest) XXX_Unmarshal added in v0.0.20 

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

type DeleteReadResponse added in v0.0.20 

type DeleteReadResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*DeleteReadResponse) Descriptor added in v0.0.20 

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

func (*DeleteReadResponse) GetStatus added in v0.0.20 

func (m *DeleteReadResponse) GetStatus() *common.Status

func (*DeleteReadResponse) ProtoMessage added in v0.0.20 

func (*DeleteReadResponse) ProtoMessage()

func (*DeleteReadResponse) Reset added in v0.0.20 

func (m *DeleteReadResponse) Reset()

func (*DeleteReadResponse) String added in v0.0.20 

func (m *DeleteReadResponse) String() string

func (*DeleteReadResponse) XXX_DiscardUnknown added in v0.0.20 

func (m *DeleteReadResponse) XXX_DiscardUnknown()

func (*DeleteReadResponse) XXX_Marshal added in v0.0.20 

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

func (*DeleteReadResponse) XXX_Merge added in v0.0.20 

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

func (*DeleteReadResponse) XXX_Size added in v0.0.20 

func (m *DeleteReadResponse) XXX_Size() int

func (*DeleteReadResponse) XXX_Unmarshal added in v0.0.20 

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

type DeleteRelayRequest 

type DeleteRelayRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	RelayId              string       `protobuf:"bytes,1,opt,name=relay_id,json=relayId,proto3" json:"relay_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*DeleteRelayRequest) Descriptor 

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

func (*DeleteRelayRequest) GetAuth 

func (m *DeleteRelayRequest) GetAuth() *common.Auth

func (*DeleteRelayRequest) GetRelayId 

func (m *DeleteRelayRequest) GetRelayId() string

func (*DeleteRelayRequest) ProtoMessage 

func (*DeleteRelayRequest) ProtoMessage()

func (*DeleteRelayRequest) Reset 

func (m *DeleteRelayRequest) Reset()

func (*DeleteRelayRequest) String 

func (m *DeleteRelayRequest) String() string

func (*DeleteRelayRequest) XXX_DiscardUnknown 

func (m *DeleteRelayRequest) XXX_DiscardUnknown()

func (*DeleteRelayRequest) XXX_Marshal 

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

func (*DeleteRelayRequest) XXX_Merge 

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

func (*DeleteRelayRequest) XXX_Size 

func (m *DeleteRelayRequest) XXX_Size() int

func (*DeleteRelayRequest) XXX_Unmarshal 

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

type DeleteRelayResponse 

type DeleteRelayResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*DeleteRelayResponse) Descriptor 

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

func (*DeleteRelayResponse) GetStatus 

func (m *DeleteRelayResponse) GetStatus() *common.Status

func (*DeleteRelayResponse) ProtoMessage 

func (*DeleteRelayResponse) ProtoMessage()

func (*DeleteRelayResponse) Reset 

func (m *DeleteRelayResponse) Reset()

func (*DeleteRelayResponse) String 

func (m *DeleteRelayResponse) String() string

func (*DeleteRelayResponse) XXX_DiscardUnknown 

func (m *DeleteRelayResponse) XXX_DiscardUnknown()

func (*DeleteRelayResponse) XXX_Marshal 

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

func (*DeleteRelayResponse) XXX_Merge 

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

func (*DeleteRelayResponse) XXX_Size 

func (m *DeleteRelayResponse) XXX_Size() int

func (*DeleteRelayResponse) XXX_Unmarshal 

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

type DeleteSchemaRequest added in v0.0.26 

type DeleteSchemaRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	Id                   string       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*DeleteSchemaRequest) Descriptor added in v0.0.26 

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

func (*DeleteSchemaRequest) GetAuth added in v0.0.26 

func (m *DeleteSchemaRequest) GetAuth() *common.Auth

func (*DeleteSchemaRequest) GetId added in v0.0.26 

func (m *DeleteSchemaRequest) GetId() string

func (*DeleteSchemaRequest) ProtoMessage added in v0.0.26 

func (*DeleteSchemaRequest) ProtoMessage()

func (*DeleteSchemaRequest) Reset added in v0.0.26 

func (m *DeleteSchemaRequest) Reset()

func (*DeleteSchemaRequest) String added in v0.0.26 

func (m *DeleteSchemaRequest) String() string

func (*DeleteSchemaRequest) XXX_DiscardUnknown added in v0.0.26 

func (m *DeleteSchemaRequest) XXX_DiscardUnknown()

func (*DeleteSchemaRequest) XXX_Marshal added in v0.0.26 

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

func (*DeleteSchemaRequest) XXX_Merge added in v0.0.26 

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

func (*DeleteSchemaRequest) XXX_Size added in v0.0.26 

func (m *DeleteSchemaRequest) XXX_Size() int

func (*DeleteSchemaRequest) XXX_Unmarshal added in v0.0.26 

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

type DeleteSchemaResponse added in v0.0.26 

type DeleteSchemaResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*DeleteSchemaResponse) Descriptor added in v0.0.26 

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

func (*DeleteSchemaResponse) GetStatus added in v0.0.26 

func (m *DeleteSchemaResponse) GetStatus() *common.Status

func (*DeleteSchemaResponse) ProtoMessage added in v0.0.26 

func (*DeleteSchemaResponse) ProtoMessage()

func (*DeleteSchemaResponse) Reset added in v0.0.26 

func (m *DeleteSchemaResponse) Reset()

func (*DeleteSchemaResponse) String added in v0.0.26 

func (m *DeleteSchemaResponse) String() string

func (*DeleteSchemaResponse) XXX_DiscardUnknown added in v0.0.26 

func (m *DeleteSchemaResponse) XXX_DiscardUnknown()

func (*DeleteSchemaResponse) XXX_Marshal added in v0.0.26 

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

func (*DeleteSchemaResponse) XXX_Merge added in v0.0.26 

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

func (*DeleteSchemaResponse) XXX_Size added in v0.0.26 

func (m *DeleteSchemaResponse) XXX_Size() int

func (*DeleteSchemaResponse) XXX_Unmarshal added in v0.0.26 

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

type DeleteServiceRequest added in v0.0.27 

type DeleteServiceRequest struct {
	Id                   string       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*DeleteServiceRequest) Descriptor added in v0.0.27 

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

func (*DeleteServiceRequest) GetAuth added in v0.0.27 

func (m *DeleteServiceRequest) GetAuth() *common.Auth

func (*DeleteServiceRequest) GetId added in v0.0.27 

func (m *DeleteServiceRequest) GetId() string

func (*DeleteServiceRequest) ProtoMessage added in v0.0.27 

func (*DeleteServiceRequest) ProtoMessage()

func (*DeleteServiceRequest) Reset added in v0.0.27 

func (m *DeleteServiceRequest) Reset()

func (*DeleteServiceRequest) String added in v0.0.27 

func (m *DeleteServiceRequest) String() string

func (*DeleteServiceRequest) XXX_DiscardUnknown added in v0.0.27 

func (m *DeleteServiceRequest) XXX_DiscardUnknown()

func (*DeleteServiceRequest) XXX_Marshal added in v0.0.27 

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

func (*DeleteServiceRequest) XXX_Merge added in v0.0.27 

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

func (*DeleteServiceRequest) XXX_Size added in v0.0.27 

func (m *DeleteServiceRequest) XXX_Size() int

func (*DeleteServiceRequest) XXX_Unmarshal added in v0.0.27 

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

type DeleteServiceResponse added in v0.0.27 

type DeleteServiceResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*DeleteServiceResponse) Descriptor added in v0.0.27 

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

func (*DeleteServiceResponse) GetStatus added in v0.0.27 

func (m *DeleteServiceResponse) GetStatus() *common.Status

func (*DeleteServiceResponse) ProtoMessage added in v0.0.27 

func (*DeleteServiceResponse) ProtoMessage()

func (*DeleteServiceResponse) Reset added in v0.0.27 

func (m *DeleteServiceResponse) Reset()

func (*DeleteServiceResponse) String added in v0.0.27 

func (m *DeleteServiceResponse) String() string

func (*DeleteServiceResponse) XXX_DiscardUnknown added in v0.0.27 

func (m *DeleteServiceResponse) XXX_DiscardUnknown()

func (*DeleteServiceResponse) XXX_Marshal added in v0.0.27 

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

func (*DeleteServiceResponse) XXX_Merge added in v0.0.27 

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

func (*DeleteServiceResponse) XXX_Size added in v0.0.27 

func (m *DeleteServiceResponse) XXX_Size() int

func (*DeleteServiceResponse) XXX_Unmarshal added in v0.0.27 

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

type GetAllConnectionsRequest 

type GetAllConnectionsRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetAllConnectionsRequest) Descriptor 

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

func (*GetAllConnectionsRequest) GetAuth 

func (m *GetAllConnectionsRequest) GetAuth() *common.Auth

func (*GetAllConnectionsRequest) ProtoMessage 

func (*GetAllConnectionsRequest) ProtoMessage()

func (*GetAllConnectionsRequest) Reset 

func (m *GetAllConnectionsRequest) Reset()

func (*GetAllConnectionsRequest) String 

func (m *GetAllConnectionsRequest) String() string

func (*GetAllConnectionsRequest) XXX_DiscardUnknown 

func (m *GetAllConnectionsRequest) XXX_DiscardUnknown()

func (*GetAllConnectionsRequest) XXX_Marshal 

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

func (*GetAllConnectionsRequest) XXX_Merge 

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

func (*GetAllConnectionsRequest) XXX_Size 

func (m *GetAllConnectionsRequest) XXX_Size() int

func (*GetAllConnectionsRequest) XXX_Unmarshal 

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

type GetAllConnectionsResponse 

type GetAllConnectionsResponse struct {
	Options              []*opts.ConnectionOptions `protobuf:"bytes,1,rep,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*GetAllConnectionsResponse) Descriptor 

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

func (*GetAllConnectionsResponse) GetOptions added in v0.0.49 

func (m *GetAllConnectionsResponse) GetOptions() []*opts.ConnectionOptions

func (*GetAllConnectionsResponse) ProtoMessage 

func (*GetAllConnectionsResponse) ProtoMessage()

func (*GetAllConnectionsResponse) Reset 

func (m *GetAllConnectionsResponse) Reset()

func (*GetAllConnectionsResponse) String 

func (m *GetAllConnectionsResponse) String() string

func (*GetAllConnectionsResponse) XXX_DiscardUnknown 

func (m *GetAllConnectionsResponse) XXX_DiscardUnknown()

func (*GetAllConnectionsResponse) XXX_Marshal 

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

func (*GetAllConnectionsResponse) XXX_Merge 

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

func (*GetAllConnectionsResponse) XXX_Size 

func (m *GetAllConnectionsResponse) XXX_Size() int

func (*GetAllConnectionsResponse) XXX_Unmarshal 

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

type GetAllReadsRequest added in v0.0.18 

type GetAllReadsRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetAllReadsRequest) Descriptor added in v0.0.18 

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

func (*GetAllReadsRequest) GetAuth added in v0.0.18 

func (m *GetAllReadsRequest) GetAuth() *common.Auth

func (*GetAllReadsRequest) ProtoMessage added in v0.0.18 

func (*GetAllReadsRequest) ProtoMessage()

func (*GetAllReadsRequest) Reset added in v0.0.18 

func (m *GetAllReadsRequest) Reset()

func (*GetAllReadsRequest) String added in v0.0.18 

func (m *GetAllReadsRequest) String() string

func (*GetAllReadsRequest) XXX_DiscardUnknown added in v0.0.18 

func (m *GetAllReadsRequest) XXX_DiscardUnknown()

func (*GetAllReadsRequest) XXX_Marshal added in v0.0.18 

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

func (*GetAllReadsRequest) XXX_Merge added in v0.0.18 

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

func (*GetAllReadsRequest) XXX_Size added in v0.0.18 

func (m *GetAllReadsRequest) XXX_Size() int

func (*GetAllReadsRequest) XXX_Unmarshal added in v0.0.18 

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

type GetAllReadsResponse added in v0.0.18 

type GetAllReadsResponse struct {
	Read                 []*opts.ReadOptions `protobuf:"bytes,1,rep,name=read,proto3" json:"read,omitempty"`
	Status               *common.Status      `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*GetAllReadsResponse) Descriptor added in v0.0.18 

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

func (*GetAllReadsResponse) GetRead added in v0.0.18 

func (m *GetAllReadsResponse) GetRead() []*opts.ReadOptions

func (*GetAllReadsResponse) GetStatus added in v0.0.18 

func (m *GetAllReadsResponse) GetStatus() *common.Status

func (*GetAllReadsResponse) ProtoMessage added in v0.0.18 

func (*GetAllReadsResponse) ProtoMessage()

func (*GetAllReadsResponse) Reset added in v0.0.18 

func (m *GetAllReadsResponse) Reset()

func (*GetAllReadsResponse) String added in v0.0.18 

func (m *GetAllReadsResponse) String() string

func (*GetAllReadsResponse) XXX_DiscardUnknown added in v0.0.18 

func (m *GetAllReadsResponse) XXX_DiscardUnknown()

func (*GetAllReadsResponse) XXX_Marshal added in v0.0.18 

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

func (*GetAllReadsResponse) XXX_Merge added in v0.0.18 

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

func (*GetAllReadsResponse) XXX_Size added in v0.0.18 

func (m *GetAllReadsResponse) XXX_Size() int

func (*GetAllReadsResponse) XXX_Unmarshal added in v0.0.18 

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

type GetAllRelaysRequest 

type GetAllRelaysRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetAllRelaysRequest) Descriptor 

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

func (*GetAllRelaysRequest) GetAuth 

func (m *GetAllRelaysRequest) GetAuth() *common.Auth

func (*GetAllRelaysRequest) ProtoMessage 

func (*GetAllRelaysRequest) ProtoMessage()

func (*GetAllRelaysRequest) Reset 

func (m *GetAllRelaysRequest) Reset()

func (*GetAllRelaysRequest) String 

func (m *GetAllRelaysRequest) String() string

func (*GetAllRelaysRequest) XXX_DiscardUnknown 

func (m *GetAllRelaysRequest) XXX_DiscardUnknown()

func (*GetAllRelaysRequest) XXX_Marshal 

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

func (*GetAllRelaysRequest) XXX_Merge 

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

func (*GetAllRelaysRequest) XXX_Size 

func (m *GetAllRelaysRequest) XXX_Size() int

func (*GetAllRelaysRequest) XXX_Unmarshal 

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

type GetAllRelaysResponse 

type GetAllRelaysResponse struct {
	Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	// Will be set as empty []Relay if no relays are configured
	Opts                 []*opts.RelayOptions `protobuf:"bytes,1,rep,name=opts,proto3" json:"opts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*GetAllRelaysResponse) Descriptor 

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

func (*GetAllRelaysResponse) GetOpts added in v0.0.49 

func (m *GetAllRelaysResponse) GetOpts() []*opts.RelayOptions

func (*GetAllRelaysResponse) GetStatus 

func (m *GetAllRelaysResponse) GetStatus() *common.Status

func (*GetAllRelaysResponse) ProtoMessage 

func (*GetAllRelaysResponse) ProtoMessage()

func (*GetAllRelaysResponse) Reset 

func (m *GetAllRelaysResponse) Reset()

func (*GetAllRelaysResponse) String 

func (m *GetAllRelaysResponse) String() string

func (*GetAllRelaysResponse) XXX_DiscardUnknown 

func (m *GetAllRelaysResponse) XXX_DiscardUnknown()

func (*GetAllRelaysResponse) XXX_Marshal 

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

func (*GetAllRelaysResponse) XXX_Merge 

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

func (*GetAllRelaysResponse) XXX_Size 

func (m *GetAllRelaysResponse) XXX_Size() int

func (*GetAllRelaysResponse) XXX_Unmarshal 

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

type GetAllSchemasRequest added in v0.0.26 

type GetAllSchemasRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetAllSchemasRequest) Descriptor added in v0.0.26 

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

func (*GetAllSchemasRequest) GetAuth added in v0.0.26 

func (m *GetAllSchemasRequest) GetAuth() *common.Auth

func (*GetAllSchemasRequest) ProtoMessage added in v0.0.26 

func (*GetAllSchemasRequest) ProtoMessage()

func (*GetAllSchemasRequest) Reset added in v0.0.26 

func (m *GetAllSchemasRequest) Reset()

func (*GetAllSchemasRequest) String added in v0.0.26 

func (m *GetAllSchemasRequest) String() string

func (*GetAllSchemasRequest) XXX_DiscardUnknown added in v0.0.26 

func (m *GetAllSchemasRequest) XXX_DiscardUnknown()

func (*GetAllSchemasRequest) XXX_Marshal added in v0.0.26 

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

func (*GetAllSchemasRequest) XXX_Merge added in v0.0.26 

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

func (*GetAllSchemasRequest) XXX_Size added in v0.0.26 

func (m *GetAllSchemasRequest) XXX_Size() int

func (*GetAllSchemasRequest) XXX_Unmarshal added in v0.0.26 

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

type GetAllSchemasResponse added in v0.0.26 

type GetAllSchemasResponse struct {
	Schema               []*Schema `protobuf:"bytes,1,rep,name=schema,proto3" json:"schema,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetAllSchemasResponse) Descriptor added in v0.0.26 

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

func (*GetAllSchemasResponse) GetSchema added in v0.0.26 

func (m *GetAllSchemasResponse) GetSchema() []*Schema

func (*GetAllSchemasResponse) ProtoMessage added in v0.0.26 

func (*GetAllSchemasResponse) ProtoMessage()

func (*GetAllSchemasResponse) Reset added in v0.0.26 

func (m *GetAllSchemasResponse) Reset()

func (*GetAllSchemasResponse) String added in v0.0.26 

func (m *GetAllSchemasResponse) String() string

func (*GetAllSchemasResponse) XXX_DiscardUnknown added in v0.0.26 

func (m *GetAllSchemasResponse) XXX_DiscardUnknown()

func (*GetAllSchemasResponse) XXX_Marshal added in v0.0.26 

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

func (*GetAllSchemasResponse) XXX_Merge added in v0.0.26 

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

func (*GetAllSchemasResponse) XXX_Size added in v0.0.26 

func (m *GetAllSchemasResponse) XXX_Size() int

func (*GetAllSchemasResponse) XXX_Unmarshal added in v0.0.26 

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

type GetAllServicesRequest added in v0.0.27 

type GetAllServicesRequest struct {
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetAllServicesRequest) Descriptor added in v0.0.27 

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

func (*GetAllServicesRequest) GetAuth added in v0.0.27 

func (m *GetAllServicesRequest) GetAuth() *common.Auth

func (*GetAllServicesRequest) ProtoMessage added in v0.0.27 

func (*GetAllServicesRequest) ProtoMessage()

func (*GetAllServicesRequest) Reset added in v0.0.27 

func (m *GetAllServicesRequest) Reset()

func (*GetAllServicesRequest) String added in v0.0.27 

func (m *GetAllServicesRequest) String() string

func (*GetAllServicesRequest) XXX_DiscardUnknown added in v0.0.27 

func (m *GetAllServicesRequest) XXX_DiscardUnknown()

func (*GetAllServicesRequest) XXX_Marshal added in v0.0.27 

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

func (*GetAllServicesRequest) XXX_Merge added in v0.0.27 

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

func (*GetAllServicesRequest) XXX_Size added in v0.0.27 

func (m *GetAllServicesRequest) XXX_Size() int

func (*GetAllServicesRequest) XXX_Unmarshal added in v0.0.27 

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

type GetAllServicesResponse added in v0.0.27 

type GetAllServicesResponse struct {
	Services             []*Service     `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetAllServicesResponse) Descriptor added in v0.0.27 

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

func (*GetAllServicesResponse) GetServices added in v0.0.27 

func (m *GetAllServicesResponse) GetServices() []*Service

func (*GetAllServicesResponse) GetStatus added in v0.0.27 

func (m *GetAllServicesResponse) GetStatus() *common.Status

func (*GetAllServicesResponse) ProtoMessage added in v0.0.27 

func (*GetAllServicesResponse) ProtoMessage()

func (*GetAllServicesResponse) Reset added in v0.0.27 

func (m *GetAllServicesResponse) Reset()

func (*GetAllServicesResponse) String added in v0.0.27 

func (m *GetAllServicesResponse) String() string

func (*GetAllServicesResponse) XXX_DiscardUnknown added in v0.0.27 

func (m *GetAllServicesResponse) XXX_DiscardUnknown()

func (*GetAllServicesResponse) XXX_Marshal added in v0.0.27 

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

func (*GetAllServicesResponse) XXX_Merge added in v0.0.27 

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

func (*GetAllServicesResponse) XXX_Size added in v0.0.27 

func (m *GetAllServicesResponse) XXX_Size() int

func (*GetAllServicesResponse) XXX_Unmarshal added in v0.0.27 

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

type GetConnectionRequest 

type GetConnectionRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	ConnectionId         string       `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetConnectionRequest) Descriptor 

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

func (*GetConnectionRequest) GetAuth 

func (m *GetConnectionRequest) GetAuth() *common.Auth

func (*GetConnectionRequest) GetConnectionId 

func (m *GetConnectionRequest) GetConnectionId() string

func (*GetConnectionRequest) ProtoMessage 

func (*GetConnectionRequest) ProtoMessage()

func (*GetConnectionRequest) Reset 

func (m *GetConnectionRequest) Reset()

func (*GetConnectionRequest) String 

func (m *GetConnectionRequest) String() string

func (*GetConnectionRequest) XXX_DiscardUnknown 

func (m *GetConnectionRequest) XXX_DiscardUnknown()

func (*GetConnectionRequest) XXX_Marshal 

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

func (*GetConnectionRequest) XXX_Merge 

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

func (*GetConnectionRequest) XXX_Size 

func (m *GetConnectionRequest) XXX_Size() int

func (*GetConnectionRequest) XXX_Unmarshal 

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

type GetConnectionResponse 

type GetConnectionResponse struct {
	Options              *opts.ConnectionOptions `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*GetConnectionResponse) Descriptor 

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

func (*GetConnectionResponse) GetOptions added in v0.0.49 

func (m *GetConnectionResponse) GetOptions() *opts.ConnectionOptions

func (*GetConnectionResponse) ProtoMessage 

func (*GetConnectionResponse) ProtoMessage()

func (*GetConnectionResponse) Reset 

func (m *GetConnectionResponse) Reset()

func (*GetConnectionResponse) String 

func (m *GetConnectionResponse) String() string

func (*GetConnectionResponse) XXX_DiscardUnknown 

func (m *GetConnectionResponse) XXX_DiscardUnknown()

func (*GetConnectionResponse) XXX_Marshal 

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

func (*GetConnectionResponse) XXX_Merge 

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

func (*GetConnectionResponse) XXX_Size 

func (m *GetConnectionResponse) XXX_Size() int

func (*GetConnectionResponse) XXX_Unmarshal 

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

type GetGithubEventsRequest added in v0.0.40 

type GetGithubEventsRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetGithubEventsRequest) Descriptor added in v0.0.40 

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

func (*GetGithubEventsRequest) GetAuth added in v0.0.40 

func (m *GetGithubEventsRequest) GetAuth() *common.Auth

func (*GetGithubEventsRequest) ProtoMessage added in v0.0.40 

func (*GetGithubEventsRequest) ProtoMessage()

func (*GetGithubEventsRequest) Reset added in v0.0.40 

func (m *GetGithubEventsRequest) Reset()

func (*GetGithubEventsRequest) String added in v0.0.40 

func (m *GetGithubEventsRequest) String() string

func (*GetGithubEventsRequest) XXX_DiscardUnknown added in v0.0.40 

func (m *GetGithubEventsRequest) XXX_DiscardUnknown()

func (*GetGithubEventsRequest) XXX_Marshal added in v0.0.40 

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

func (*GetGithubEventsRequest) XXX_Merge added in v0.0.40 

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

func (*GetGithubEventsRequest) XXX_Size added in v0.0.40 

func (m *GetGithubEventsRequest) XXX_Size() int

func (*GetGithubEventsRequest) XXX_Unmarshal added in v0.0.40 

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

type GetRelayRequest 

type GetRelayRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	RelayId              string       `protobuf:"bytes,1,opt,name=relay_id,json=relayId,proto3" json:"relay_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetRelayRequest) Descriptor 

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

func (*GetRelayRequest) GetAuth 

func (m *GetRelayRequest) GetAuth() *common.Auth

func (*GetRelayRequest) GetRelayId 

func (m *GetRelayRequest) GetRelayId() string

func (*GetRelayRequest) ProtoMessage 

func (*GetRelayRequest) ProtoMessage()

func (*GetRelayRequest) Reset 

func (m *GetRelayRequest) Reset()

func (*GetRelayRequest) String 

func (m *GetRelayRequest) String() string

func (*GetRelayRequest) XXX_DiscardUnknown 

func (m *GetRelayRequest) XXX_DiscardUnknown()

func (*GetRelayRequest) XXX_Marshal 

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

func (*GetRelayRequest) XXX_Merge 

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

func (*GetRelayRequest) XXX_Size 

func (m *GetRelayRequest) XXX_Size() int

func (*GetRelayRequest) XXX_Unmarshal 

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

type GetRelayResponse 

type GetRelayResponse struct {
	Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	// Set only if status is OK
	Opts                 *opts.RelayOptions `protobuf:"bytes,1,opt,name=opts,proto3" json:"opts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*GetRelayResponse) Descriptor 

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

func (*GetRelayResponse) GetOpts added in v0.0.49 

func (m *GetRelayResponse) GetOpts() *opts.RelayOptions

func (*GetRelayResponse) GetStatus 

func (m *GetRelayResponse) GetStatus() *common.Status

func (*GetRelayResponse) ProtoMessage 

func (*GetRelayResponse) ProtoMessage()

func (*GetRelayResponse) Reset 

func (m *GetRelayResponse) Reset()

func (*GetRelayResponse) String 

func (m *GetRelayResponse) String() string

func (*GetRelayResponse) XXX_DiscardUnknown 

func (m *GetRelayResponse) XXX_DiscardUnknown()

func (*GetRelayResponse) XXX_Marshal 

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

func (*GetRelayResponse) XXX_Merge 

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

func (*GetRelayResponse) XXX_Size 

func (m *GetRelayResponse) XXX_Size() int

func (*GetRelayResponse) XXX_Unmarshal 

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

type GetSchemaRequest added in v0.0.26 

type GetSchemaRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	Id                   string       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetSchemaRequest) Descriptor added in v0.0.26 

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

func (*GetSchemaRequest) GetAuth added in v0.0.26 

func (m *GetSchemaRequest) GetAuth() *common.Auth

func (*GetSchemaRequest) GetId added in v0.0.26 

func (m *GetSchemaRequest) GetId() string

func (*GetSchemaRequest) ProtoMessage added in v0.0.26 

func (*GetSchemaRequest) ProtoMessage()

func (*GetSchemaRequest) Reset added in v0.0.26 

func (m *GetSchemaRequest) Reset()

func (*GetSchemaRequest) String added in v0.0.26 

func (m *GetSchemaRequest) String() string

func (*GetSchemaRequest) XXX_DiscardUnknown added in v0.0.26 

func (m *GetSchemaRequest) XXX_DiscardUnknown()

func (*GetSchemaRequest) XXX_Marshal added in v0.0.26 

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

func (*GetSchemaRequest) XXX_Merge added in v0.0.26 

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

func (*GetSchemaRequest) XXX_Size added in v0.0.26 

func (m *GetSchemaRequest) XXX_Size() int

func (*GetSchemaRequest) XXX_Unmarshal added in v0.0.26 

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

type GetSchemaResponse added in v0.0.26 

type GetSchemaResponse struct {
	Schema               *Schema  `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetSchemaResponse) Descriptor added in v0.0.26 

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

func (*GetSchemaResponse) GetSchema added in v0.0.26 

func (m *GetSchemaResponse) GetSchema() *Schema

func (*GetSchemaResponse) ProtoMessage added in v0.0.26 

func (*GetSchemaResponse) ProtoMessage()

func (*GetSchemaResponse) Reset added in v0.0.26 

func (m *GetSchemaResponse) Reset()

func (*GetSchemaResponse) String added in v0.0.26 

func (m *GetSchemaResponse) String() string

func (*GetSchemaResponse) XXX_DiscardUnknown added in v0.0.26 

func (m *GetSchemaResponse) XXX_DiscardUnknown()

func (*GetSchemaResponse) XXX_Marshal added in v0.0.26 

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

func (*GetSchemaResponse) XXX_Merge added in v0.0.26 

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

func (*GetSchemaResponse) XXX_Size added in v0.0.26 

func (m *GetSchemaResponse) XXX_Size() int

func (*GetSchemaResponse) XXX_Unmarshal added in v0.0.26 

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

type GetServerOptionsRequest added in v0.0.49 

type GetServerOptionsRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetServerOptionsRequest) Descriptor added in v0.0.49 

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

func (*GetServerOptionsRequest) GetAuth added in v0.0.49 

func (m *GetServerOptionsRequest) GetAuth() *common.Auth

func (*GetServerOptionsRequest) ProtoMessage added in v0.0.49 

func (*GetServerOptionsRequest) ProtoMessage()

func (*GetServerOptionsRequest) Reset added in v0.0.49 

func (m *GetServerOptionsRequest) Reset()

func (*GetServerOptionsRequest) String added in v0.0.49 

func (m *GetServerOptionsRequest) String() string

func (*GetServerOptionsRequest) XXX_DiscardUnknown added in v0.0.49 

func (m *GetServerOptionsRequest) XXX_DiscardUnknown()

func (*GetServerOptionsRequest) XXX_Marshal added in v0.0.49 

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

func (*GetServerOptionsRequest) XXX_Merge added in v0.0.49 

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

func (*GetServerOptionsRequest) XXX_Size added in v0.0.49 

func (m *GetServerOptionsRequest) XXX_Size() int

func (*GetServerOptionsRequest) XXX_Unmarshal added in v0.0.49 

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

type GetServerOptionsResponse added in v0.0.49 

type GetServerOptionsResponse struct {
	ServerOptions        *opts.ServerOptions `protobuf:"bytes,1,opt,name=server_options,json=serverOptions,proto3" json:"server_options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*GetServerOptionsResponse) Descriptor added in v0.0.49 

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

func (*GetServerOptionsResponse) GetServerOptions added in v0.0.49 

func (m *GetServerOptionsResponse) GetServerOptions() *opts.ServerOptions

func (*GetServerOptionsResponse) ProtoMessage added in v0.0.49 

func (*GetServerOptionsResponse) ProtoMessage()

func (*GetServerOptionsResponse) Reset added in v0.0.49 

func (m *GetServerOptionsResponse) Reset()

func (*GetServerOptionsResponse) String added in v0.0.49 

func (m *GetServerOptionsResponse) String() string

func (*GetServerOptionsResponse) XXX_DiscardUnknown added in v0.0.49 

func (m *GetServerOptionsResponse) XXX_DiscardUnknown()

func (*GetServerOptionsResponse) XXX_Marshal added in v0.0.49 

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

func (*GetServerOptionsResponse) XXX_Merge added in v0.0.49 

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

func (*GetServerOptionsResponse) XXX_Size added in v0.0.49 

func (m *GetServerOptionsResponse) XXX_Size() int

func (*GetServerOptionsResponse) XXX_Unmarshal added in v0.0.49 

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

type GetServiceRequest added in v0.0.27 

type GetServiceRequest struct {
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	Id                   string       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetServiceRequest) Descriptor added in v0.0.27 

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

func (*GetServiceRequest) GetAuth added in v0.0.27 

func (m *GetServiceRequest) GetAuth() *common.Auth

func (*GetServiceRequest) GetId added in v0.0.27 

func (m *GetServiceRequest) GetId() string

func (*GetServiceRequest) ProtoMessage added in v0.0.27 

func (*GetServiceRequest) ProtoMessage()

func (*GetServiceRequest) Reset added in v0.0.27 

func (m *GetServiceRequest) Reset()

func (*GetServiceRequest) String added in v0.0.27 

func (m *GetServiceRequest) String() string

func (*GetServiceRequest) XXX_DiscardUnknown added in v0.0.27 

func (m *GetServiceRequest) XXX_DiscardUnknown()

func (*GetServiceRequest) XXX_Marshal added in v0.0.27 

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

func (*GetServiceRequest) XXX_Merge added in v0.0.27 

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

func (*GetServiceRequest) XXX_Size added in v0.0.27 

func (m *GetServiceRequest) XXX_Size() int

func (*GetServiceRequest) XXX_Unmarshal added in v0.0.27 

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

type GetServiceResponse added in v0.0.27 

type GetServiceResponse struct {
	Service              *Service       `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetServiceResponse) Descriptor added in v0.0.27 

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

func (*GetServiceResponse) GetService added in v0.0.27 

func (m *GetServiceResponse) GetService() *Service

func (*GetServiceResponse) GetStatus added in v0.0.27 

func (m *GetServiceResponse) GetStatus() *common.Status

func (*GetServiceResponse) ProtoMessage added in v0.0.27 

func (*GetServiceResponse) ProtoMessage()

func (*GetServiceResponse) Reset added in v0.0.27 

func (m *GetServiceResponse) Reset()

func (*GetServiceResponse) String added in v0.0.27 

func (m *GetServiceResponse) String() string

func (*GetServiceResponse) XXX_DiscardUnknown added in v0.0.27 

func (m *GetServiceResponse) XXX_DiscardUnknown()

func (*GetServiceResponse) XXX_Marshal added in v0.0.27 

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

func (*GetServiceResponse) XXX_Merge added in v0.0.27 

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

func (*GetServiceResponse) XXX_Size added in v0.0.27 

func (m *GetServiceResponse) XXX_Size() int

func (*GetServiceResponse) XXX_Unmarshal added in v0.0.27 

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

type GithubEvent added in v0.0.40 

type GithubEvent struct {
	Type GithubEvent_Type `protobuf:"varint,1,opt,name=type,proto3,enum=protos.GithubEvent_Type" json:"type,omitempty"`
	// Types that are valid to be assigned to Payload:
	//	*GithubEvent_AuthResponse
	//	*GithubEvent_InstallCreated
	//	*GithubEvent_InstallUpdated
	//	*GithubEvent_InstallDeleted
	//	*GithubEvent_PrCreated
	//	*GithubEvent_PrMerged
	Payload              isGithubEvent_Payload `protobuf_oneof:"payload"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

GithubEvent is sent by batchcorp/github-service and received by Plumber instances to be acted upon It is also sent to the frontend to be acted upon See the following URL for reference to events we are receiving from github https://docs.github.com/en/developers/webhooks-and-events/webhooks/webhook-events-and-payloads#

func (*GithubEvent) Descriptor added in v0.0.40 

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

func (*GithubEvent) GetAuthResponse added in v0.0.41 

func (m *GithubEvent) GetAuthResponse() *AuthResponse

func (*GithubEvent) GetInstallCreated added in v0.0.40 

func (m *GithubEvent) GetInstallCreated() *InstallCreated

func (*GithubEvent) GetInstallDeleted added in v0.0.40 

func (m *GithubEvent) GetInstallDeleted() *InstallDeleted

func (*GithubEvent) GetInstallUpdated added in v0.0.40 

func (m *GithubEvent) GetInstallUpdated() *InstallUpdated

func (*GithubEvent) GetPayload added in v0.0.40 

func (m *GithubEvent) GetPayload() isGithubEvent_Payload

func (*GithubEvent) GetPrCreated added in v0.0.40 

func (m *GithubEvent) GetPrCreated() *PullRequestCreated

func (*GithubEvent) GetPrMerged added in v0.0.40 

func (m *GithubEvent) GetPrMerged() *PullRequestMerged

func (*GithubEvent) GetType added in v0.0.41 

func (m *GithubEvent) GetType() GithubEvent_Type

func (*GithubEvent) ProtoMessage added in v0.0.40 

func (*GithubEvent) ProtoMessage()

func (*GithubEvent) Reset added in v0.0.40 

func (m *GithubEvent) Reset()

func (*GithubEvent) String added in v0.0.40 

func (m *GithubEvent) String() string

func (*GithubEvent) XXX_DiscardUnknown added in v0.0.40 

func (m *GithubEvent) XXX_DiscardUnknown()

func (*GithubEvent) XXX_Marshal added in v0.0.40 

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

func (*GithubEvent) XXX_Merge added in v0.0.40 

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

func (*GithubEvent) XXX_OneofWrappers added in v0.0.40 

func (*GithubEvent) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*GithubEvent) XXX_Size added in v0.0.40 

func (m *GithubEvent) XXX_Size() int

func (*GithubEvent) XXX_Unmarshal added in v0.0.40 

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

type GithubEvent_AuthResponse added in v0.0.41 

type GithubEvent_AuthResponse struct {
	AuthResponse *AuthResponse `protobuf:"bytes,100,opt,name=auth_response,json=authResponse,proto3,oneof"`
}

type GithubEvent_InstallCreated added in v0.0.40 

type GithubEvent_InstallCreated struct {
	InstallCreated *InstallCreated `protobuf:"bytes,101,opt,name=install_created,json=installCreated,proto3,oneof"`
}

type GithubEvent_InstallDeleted added in v0.0.40 

type GithubEvent_InstallDeleted struct {
	InstallDeleted *InstallDeleted `protobuf:"bytes,103,opt,name=install_deleted,json=installDeleted,proto3,oneof"`
}

type GithubEvent_InstallUpdated added in v0.0.40 

type GithubEvent_InstallUpdated struct {
	InstallUpdated *InstallUpdated `protobuf:"bytes,102,opt,name=install_updated,json=installUpdated,proto3,oneof"`
}

type GithubEvent_PrCreated added in v0.0.40 

type GithubEvent_PrCreated struct {
	PrCreated *PullRequestCreated `protobuf:"bytes,104,opt,name=pr_created,json=prCreated,proto3,oneof"`
}

type GithubEvent_PrMerged added in v0.0.40 

type GithubEvent_PrMerged struct {
	PrMerged *PullRequestMerged `protobuf:"bytes,105,opt,name=pr_merged,json=prMerged,proto3,oneof"`
}

type GithubEvent_Type added in v0.0.41 

type GithubEvent_Type int32
const (
	GithubEvent_UNSET           GithubEvent_Type = 0
	GithubEvent_AUTH_RESPONSE   GithubEvent_Type = 1
	GithubEvent_INSTALL_CREATED GithubEvent_Type = 2
	GithubEvent_INSTALL_UPDATED GithubEvent_Type = 3
	GithubEvent_INSTALL_DELETED GithubEvent_Type = 4
	GithubEvent_PULL_CREATED    GithubEvent_Type = 5
	GithubEvent_PULL_MERGED     GithubEvent_Type = 6
)

func (GithubEvent_Type) EnumDescriptor added in v0.0.41 

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

func (GithubEvent_Type) String added in v0.0.41 

func (x GithubEvent_Type) String() string

type GithubServerClient added in v0.0.41 

type GithubServerClient interface {
	Connect(ctx context.Context, in *ConnectAuthRequest, opts ...grpc.CallOption) (GithubServer_ConnectClient, error)
}

GithubServerClient is the client API for GithubServer service.

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

func NewGithubServerClient added in v0.0.41 

func NewGithubServerClient(cc *grpc.ClientConn) GithubServerClient

type GithubServerServer added in v0.0.41 

type GithubServerServer interface {
	Connect(*ConnectAuthRequest, GithubServer_ConnectServer) error
}

GithubServerServer is the server API for GithubServer service.

type GithubServer_ConnectClient added in v0.0.41 

type GithubServer_ConnectClient interface {
	Recv() (*GithubEvent, error)
	grpc.ClientStream
}

type GithubServer_ConnectServer added in v0.0.41 

type GithubServer_ConnectServer interface {
	Send(*GithubEvent) error
	grpc.ServerStream
}

type ImportGithubRequest added in v0.0.26 

type ImportGithubRequest struct {
	// Every gRPC request must have a valid auth config
	Auth      *common.Auth        `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	Name      string              `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type      encoding.EncodeType `protobuf:"varint,2,opt,name=type,proto3,enum=protos.encoding.EncodeType" json:"type,omitempty"`
	GithubUrl string              `protobuf:"bytes,3,opt,name=github_url,json=githubUrl,proto3" json:"github_url,omitempty"`
	// Protobuf only, root message name
	RootType string `protobuf:"bytes,4,opt,name=root_type,json=rootType,proto3" json:"root_type,omitempty"`
	// Directory inside github repo where protos are stored
	RootDir              string   `protobuf:"bytes,5,opt,name=root_dir,json=rootDir,proto3" json:"root_dir,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ImportGithubRequest) Descriptor added in v0.0.26 

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

func (*ImportGithubRequest) GetAuth added in v0.0.26 

func (m *ImportGithubRequest) GetAuth() *common.Auth

func (*ImportGithubRequest) GetGithubUrl added in v0.0.26 

func (m *ImportGithubRequest) GetGithubUrl() string

func (*ImportGithubRequest) GetName added in v0.0.26 

func (m *ImportGithubRequest) GetName() string

func (*ImportGithubRequest) GetRootDir added in v0.0.28 

func (m *ImportGithubRequest) GetRootDir() string

func (*ImportGithubRequest) GetRootType added in v0.0.26 

func (m *ImportGithubRequest) GetRootType() string

func (*ImportGithubRequest) GetType added in v0.0.26 

func (m *ImportGithubRequest) GetType() encoding.EncodeType

func (*ImportGithubRequest) ProtoMessage added in v0.0.26 

func (*ImportGithubRequest) ProtoMessage()

func (*ImportGithubRequest) Reset added in v0.0.26 

func (m *ImportGithubRequest) Reset()

func (*ImportGithubRequest) String added in v0.0.26 

func (m *ImportGithubRequest) String() string

func (*ImportGithubRequest) XXX_DiscardUnknown added in v0.0.26 

func (m *ImportGithubRequest) XXX_DiscardUnknown()

func (*ImportGithubRequest) XXX_Marshal added in v0.0.26 

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

func (*ImportGithubRequest) XXX_Merge added in v0.0.26 

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

func (*ImportGithubRequest) XXX_Size added in v0.0.26 

func (m *ImportGithubRequest) XXX_Size() int

func (*ImportGithubRequest) XXX_Unmarshal added in v0.0.26 

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

type ImportGithubResponse added in v0.0.26 

type ImportGithubResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	Id                   string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ImportGithubResponse) Descriptor added in v0.0.26 

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

func (*ImportGithubResponse) GetId added in v0.0.26 

func (m *ImportGithubResponse) GetId() string

func (*ImportGithubResponse) GetStatus added in v0.0.26 

func (m *ImportGithubResponse) GetStatus() *common.Status

func (*ImportGithubResponse) ProtoMessage added in v0.0.26 

func (*ImportGithubResponse) ProtoMessage()

func (*ImportGithubResponse) Reset added in v0.0.26 

func (m *ImportGithubResponse) Reset()

func (*ImportGithubResponse) String added in v0.0.26 

func (m *ImportGithubResponse) String() string

func (*ImportGithubResponse) XXX_DiscardUnknown added in v0.0.26 

func (m *ImportGithubResponse) XXX_DiscardUnknown()

func (*ImportGithubResponse) XXX_Marshal added in v0.0.26 

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

func (*ImportGithubResponse) XXX_Merge added in v0.0.26 

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

func (*ImportGithubResponse) XXX_Size added in v0.0.26 

func (m *ImportGithubResponse) XXX_Size() int

func (*ImportGithubResponse) XXX_Unmarshal added in v0.0.26 

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

type ImportLocalRequest added in v0.0.26 

type ImportLocalRequest struct {
	// Every gRPC request must have a valid auth config
	Auth       *common.Auth        `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	Name       string              `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type       encoding.EncodeType `protobuf:"varint,2,opt,name=type,proto3,enum=protos.encoding.EncodeType" json:"type,omitempty"`
	ZipArchive []byte              `protobuf:"bytes,3,opt,name=zip_archive,json=zipArchive,proto3" json:"zip_archive,omitempty"`
	// Protobuf only, root message name
	RootType             string   `protobuf:"bytes,4,opt,name=root_type,json=rootType,proto3" json:"root_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ImportLocalRequest) Descriptor added in v0.0.26 

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

func (*ImportLocalRequest) GetAuth added in v0.0.26 

func (m *ImportLocalRequest) GetAuth() *common.Auth

func (*ImportLocalRequest) GetName added in v0.0.26 

func (m *ImportLocalRequest) GetName() string

func (*ImportLocalRequest) GetRootType added in v0.0.26 

func (m *ImportLocalRequest) GetRootType() string

func (*ImportLocalRequest) GetType added in v0.0.26 

func (m *ImportLocalRequest) GetType() encoding.EncodeType

func (*ImportLocalRequest) GetZipArchive added in v0.0.26 

func (m *ImportLocalRequest) GetZipArchive() []byte

func (*ImportLocalRequest) ProtoMessage added in v0.0.26 

func (*ImportLocalRequest) ProtoMessage()

func (*ImportLocalRequest) Reset added in v0.0.26 

func (m *ImportLocalRequest) Reset()

func (*ImportLocalRequest) String added in v0.0.26 

func (m *ImportLocalRequest) String() string

func (*ImportLocalRequest) XXX_DiscardUnknown added in v0.0.26 

func (m *ImportLocalRequest) XXX_DiscardUnknown()

func (*ImportLocalRequest) XXX_Marshal added in v0.0.26 

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

func (*ImportLocalRequest) XXX_Merge added in v0.0.26 

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

func (*ImportLocalRequest) XXX_Size added in v0.0.26 

func (m *ImportLocalRequest) XXX_Size() int

func (*ImportLocalRequest) XXX_Unmarshal added in v0.0.26 

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

type ImportLocalResponse added in v0.0.26 

type ImportLocalResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	Id                   string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ImportLocalResponse) Descriptor added in v0.0.26 

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

func (*ImportLocalResponse) GetId added in v0.0.26 

func (m *ImportLocalResponse) GetId() string

func (*ImportLocalResponse) GetStatus added in v0.0.26 

func (m *ImportLocalResponse) GetStatus() *common.Status

func (*ImportLocalResponse) ProtoMessage added in v0.0.26 

func (*ImportLocalResponse) ProtoMessage()

func (*ImportLocalResponse) Reset added in v0.0.26 

func (m *ImportLocalResponse) Reset()

func (*ImportLocalResponse) String added in v0.0.26 

func (m *ImportLocalResponse) String() string

func (*ImportLocalResponse) XXX_DiscardUnknown added in v0.0.26 

func (m *ImportLocalResponse) XXX_DiscardUnknown()

func (*ImportLocalResponse) XXX_Marshal added in v0.0.26 

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

func (*ImportLocalResponse) XXX_Merge added in v0.0.26 

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

func (*ImportLocalResponse) XXX_Size added in v0.0.26 

func (m *ImportLocalResponse) XXX_Size() int

func (*ImportLocalResponse) XXX_Unmarshal added in v0.0.26 

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

type InstallCreated added in v0.0.40 

type InstallCreated struct {
	InstallId            int64    `protobuf:"varint,1,opt,name=install_id,json=installId,proto3" json:"install_id,omitempty"`
	AccountId            int64    `protobuf:"varint,2,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Sent by github-service and received by plumber Sent by plumber, received by UI

func (*InstallCreated) Descriptor added in v0.0.40 

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

func (*InstallCreated) GetAccountId added in v0.0.40 

func (m *InstallCreated) GetAccountId() int64

func (*InstallCreated) GetInstallId added in v0.0.40 

func (m *InstallCreated) GetInstallId() int64

func (*InstallCreated) ProtoMessage added in v0.0.40 

func (*InstallCreated) ProtoMessage()

func (*InstallCreated) Reset added in v0.0.40 

func (m *InstallCreated) Reset()

func (*InstallCreated) String added in v0.0.40 

func (m *InstallCreated) String() string

func (*InstallCreated) XXX_DiscardUnknown added in v0.0.40 

func (m *InstallCreated) XXX_DiscardUnknown()

func (*InstallCreated) XXX_Marshal added in v0.0.40 

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

func (*InstallCreated) XXX_Merge added in v0.0.40 

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

func (*InstallCreated) XXX_Size added in v0.0.40 

func (m *InstallCreated) XXX_Size() int

func (*InstallCreated) XXX_Unmarshal added in v0.0.40 

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

type InstallDeleted added in v0.0.40 

type InstallDeleted struct {
	InstallId            int64    `protobuf:"varint,1,opt,name=install_id,json=installId,proto3" json:"install_id,omitempty"`
	AccountId            int64    `protobuf:"varint,2,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Sent by github-service and received by plumber Sent by plumber, received by UI

func (*InstallDeleted) Descriptor added in v0.0.40 

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

func (*InstallDeleted) GetAccountId added in v0.0.40 

func (m *InstallDeleted) GetAccountId() int64

func (*InstallDeleted) GetInstallId added in v0.0.40 

func (m *InstallDeleted) GetInstallId() int64

func (*InstallDeleted) ProtoMessage added in v0.0.40 

func (*InstallDeleted) ProtoMessage()

func (*InstallDeleted) Reset added in v0.0.40 

func (m *InstallDeleted) Reset()

func (*InstallDeleted) String added in v0.0.40 

func (m *InstallDeleted) String() string

func (*InstallDeleted) XXX_DiscardUnknown added in v0.0.40 

func (m *InstallDeleted) XXX_DiscardUnknown()

func (*InstallDeleted) XXX_Marshal added in v0.0.40 

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

func (*InstallDeleted) XXX_Merge added in v0.0.40 

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

func (*InstallDeleted) XXX_Size added in v0.0.40 

func (m *InstallDeleted) XXX_Size() int

func (*InstallDeleted) XXX_Unmarshal added in v0.0.40 

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

type InstallUpdated added in v0.0.40 

type InstallUpdated struct {
	InstallId            int64    `protobuf:"varint,1,opt,name=install_id,json=installId,proto3" json:"install_id,omitempty"`
	AccountId            int64    `protobuf:"varint,2,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Sent by github-service and received by plumber Sent by plumber, received by UI

func (*InstallUpdated) Descriptor added in v0.0.40 

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

func (*InstallUpdated) GetAccountId added in v0.0.40 

func (m *InstallUpdated) GetAccountId() int64

func (*InstallUpdated) GetInstallId added in v0.0.40 

func (m *InstallUpdated) GetInstallId() int64

func (*InstallUpdated) ProtoMessage added in v0.0.40 

func (*InstallUpdated) ProtoMessage()

func (*InstallUpdated) Reset added in v0.0.40 

func (m *InstallUpdated) Reset()

func (*InstallUpdated) String added in v0.0.40 

func (m *InstallUpdated) String() string

func (*InstallUpdated) XXX_DiscardUnknown added in v0.0.40 

func (m *InstallUpdated) XXX_DiscardUnknown()

func (*InstallUpdated) XXX_Marshal added in v0.0.40 

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

func (*InstallUpdated) XXX_Merge added in v0.0.40 

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

func (*InstallUpdated) XXX_Size added in v0.0.40 

func (m *InstallUpdated) XXX_Size() int

func (*InstallUpdated) XXX_Unmarshal added in v0.0.40 

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

type IsGithubAuthRequest added in v0.0.25 

type IsGithubAuthRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*IsGithubAuthRequest) Descriptor added in v0.0.25 

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

func (*IsGithubAuthRequest) GetAuth added in v0.0.25 

func (m *IsGithubAuthRequest) GetAuth() *common.Auth

func (*IsGithubAuthRequest) ProtoMessage added in v0.0.25 

func (*IsGithubAuthRequest) ProtoMessage()

func (*IsGithubAuthRequest) Reset added in v0.0.25 

func (m *IsGithubAuthRequest) Reset()

func (*IsGithubAuthRequest) String added in v0.0.25 

func (m *IsGithubAuthRequest) String() string

func (*IsGithubAuthRequest) XXX_DiscardUnknown added in v0.0.25 

func (m *IsGithubAuthRequest) XXX_DiscardUnknown()

func (*IsGithubAuthRequest) XXX_Marshal added in v0.0.25 

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

func (*IsGithubAuthRequest) XXX_Merge added in v0.0.25 

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

func (*IsGithubAuthRequest) XXX_Size added in v0.0.25 

func (m *IsGithubAuthRequest) XXX_Size() int

func (*IsGithubAuthRequest) XXX_Unmarshal added in v0.0.25 

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

type IsGithubAuthResponse added in v0.0.25 

type IsGithubAuthResponse struct {
	Authorized           bool     `protobuf:"varint,1,opt,name=authorized,proto3" json:"authorized,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IsGithubAuthResponse) Descriptor added in v0.0.25 

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

func (*IsGithubAuthResponse) GetAuthorized added in v0.0.25 

func (m *IsGithubAuthResponse) GetAuthorized() bool

func (*IsGithubAuthResponse) ProtoMessage added in v0.0.25 

func (*IsGithubAuthResponse) ProtoMessage()

func (*IsGithubAuthResponse) Reset added in v0.0.25 

func (m *IsGithubAuthResponse) Reset()

func (*IsGithubAuthResponse) String added in v0.0.25 

func (m *IsGithubAuthResponse) String() string

func (*IsGithubAuthResponse) XXX_DiscardUnknown added in v0.0.25 

func (m *IsGithubAuthResponse) XXX_DiscardUnknown()

func (*IsGithubAuthResponse) XXX_Marshal added in v0.0.25 

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

func (*IsGithubAuthResponse) XXX_Merge added in v0.0.25 

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

func (*IsGithubAuthResponse) XXX_Size added in v0.0.25 

func (m *IsGithubAuthResponse) XXX_Size() int

func (*IsGithubAuthResponse) XXX_Unmarshal added in v0.0.25 

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

type IsGithubEvent_Payload added in v0.0.49 

type IsGithubEvent_Payload = isGithubEvent_Payload

type PlumberServerClient 

type PlumberServerClient interface {
	// List configured/known connections
	GetAllConnections(ctx context.Context, in *GetAllConnectionsRequest, opts ...grpc.CallOption) (*GetAllConnectionsResponse, error)
	// Fetch a specific connection by ID
	GetConnection(ctx context.Context, in *GetConnectionRequest, opts ...grpc.CallOption) (*GetConnectionResponse, error)
	// Create a connection in plumber
	CreateConnection(ctx context.Context, in *CreateConnectionRequest, opts ...grpc.CallOption) (*CreateConnectionResponse, error)
	// Test a connection before saving its configuration
	TestConnection(ctx context.Context, in *TestConnectionRequest, opts ...grpc.CallOption) (*TestConnectionResponse, error)
	// Any active connections will be restarted
	UpdateConnection(ctx context.Context, in *UpdateConnectionRequest, opts ...grpc.CallOption) (*UpdateConnectionResponse, error)
	// If there are any active connections, delete will cause them to get closed
	DeleteConnection(ctx context.Context, in *DeleteConnectionRequest, opts ...grpc.CallOption) (*DeleteConnectionResponse, error)
	// Start reading data from a connection
	CreateRead(ctx context.Context, in *CreateReadRequest, opts ...grpc.CallOption) (*CreateReadResponse, error)
	// Streams messages received off of a read
	StartRead(ctx context.Context, in *StartReadRequest, opts ...grpc.CallOption) (PlumberServer_StartReadClient, error)
	// List all reads that have been created
	GetAllReads(ctx context.Context, in *GetAllReadsRequest, opts ...grpc.CallOption) (*GetAllReadsResponse, error)
	// Stop reading data from a connection
	StopRead(ctx context.Context, in *StopReadRequest, opts ...grpc.CallOption) (*StopReadResponse, error)
	// Resume reading data from an existing read
	ResumeRead(ctx context.Context, in *ResumeReadRequest, opts ...grpc.CallOption) (*ResumeReadResponse, error)
	// Resume reading data from an existing read
	DeleteRead(ctx context.Context, in *DeleteReadRequest, opts ...grpc.CallOption) (*DeleteReadResponse, error)
	// Write data to a connection
	Write(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error)
	// Create a data relay from plumber server to the Batch platform
	CreateRelay(ctx context.Context, in *CreateRelayRequest, opts ...grpc.CallOption) (*CreateRelayResponse, error)
	// Update a relay (such as API token) - relay will be interrupted!
	UpdateRelay(ctx context.Context, in *UpdateRelayRequest, opts ...grpc.CallOption) (*UpdateRelayResponse, error)
	ResumeRelay(ctx context.Context, in *ResumeRelayRequest, opts ...grpc.CallOption) (*ResumeRelayResponse, error)
	StopRelay(ctx context.Context, in *StopRelayRequest, opts ...grpc.CallOption) (*StopRelayResponse, error)
	GetAllRelays(ctx context.Context, in *GetAllRelaysRequest, opts ...grpc.CallOption) (*GetAllRelaysResponse, error)
	// Delete an existing relay
	DeleteRelay(ctx context.Context, in *DeleteRelayRequest, opts ...grpc.CallOption) (*DeleteRelayResponse, error)
	// Begins github authorization process
	StartGithubAuth(ctx context.Context, in *StartGithubAuthRequest, opts ...grpc.CallOption) (*StartGithubAuthResponse, error)
	// Starts a poll of the github authorization status
	PollGithubAuth(ctx context.Context, in *PollGithubAuthRequest, opts ...grpc.CallOption) (PlumberServer_PollGithubAuthClient, error)
	// Determines if we have authorized plumber with github
	IsGithubAuth(ctx context.Context, in *IsGithubAuthRequest, opts ...grpc.CallOption) (*IsGithubAuthResponse, error)
	// Retrieve a single schema
	GetSchema(ctx context.Context, in *GetSchemaRequest, opts ...grpc.CallOption) (*GetSchemaResponse, error)
	// Retrieve all schemas
	GetAllSchemas(ctx context.Context, in *GetAllSchemasRequest, opts ...grpc.CallOption) (*GetAllSchemasResponse, error)
	// Import a schema from github
	ImportGithub(ctx context.Context, in *ImportGithubRequest, opts ...grpc.CallOption) (*ImportGithubResponse, error)
	// Import a schema from the local file system
	ImportLocal(ctx context.Context, in *ImportLocalRequest, opts ...grpc.CallOption) (*ImportLocalResponse, error)
	// Delete a schema
	DeleteSchema(ctx context.Context, in *DeleteSchemaRequest, opts ...grpc.CallOption) (*DeleteSchemaResponse, error)
	GetService(ctx context.Context, in *GetServiceRequest, opts ...grpc.CallOption) (*GetServiceResponse, error)
	GetAllServices(ctx context.Context, in *GetAllServicesRequest, opts ...grpc.CallOption) (*GetAllServicesResponse, error)
	CreateService(ctx context.Context, in *CreateServiceRequest, opts ...grpc.CallOption) (*CreateServiceResponse, error)
	UpdateService(ctx context.Context, in *UpdateServiceRequest, opts ...grpc.CallOption) (*UpdateServiceResponse, error)
	DeleteService(ctx context.Context, in *DeleteServiceRequest, opts ...grpc.CallOption) (*DeleteServiceResponse, error)
	GetServerOptions(ctx context.Context, in *GetServerOptionsRequest, opts ...grpc.CallOption) (*GetServerOptionsResponse, error)
	// GetGithubEvents connects to github-app backend and returns a stream of events pushed from github
	GetGithubEvents(ctx context.Context, in *GetGithubEventsRequest, opts ...grpc.CallOption) (PlumberServer_GetGithubEventsClient, error)
}

PlumberServerClient is the client API for PlumberServer service.

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

func NewPlumberServerClient 

func NewPlumberServerClient(cc *grpc.ClientConn) PlumberServerClient

type PlumberServerServer 

type PlumberServerServer interface {
	// List configured/known connections
	GetAllConnections(context.Context, *GetAllConnectionsRequest) (*GetAllConnectionsResponse, error)
	// Fetch a specific connection by ID
	GetConnection(context.Context, *GetConnectionRequest) (*GetConnectionResponse, error)
	// Create a connection in plumber
	CreateConnection(context.Context, *CreateConnectionRequest) (*CreateConnectionResponse, error)
	// Test a connection before saving its configuration
	TestConnection(context.Context, *TestConnectionRequest) (*TestConnectionResponse, error)
	// Any active connections will be restarted
	UpdateConnection(context.Context, *UpdateConnectionRequest) (*UpdateConnectionResponse, error)
	// If there are any active connections, delete will cause them to get closed
	DeleteConnection(context.Context, *DeleteConnectionRequest) (*DeleteConnectionResponse, error)
	// Start reading data from a connection
	CreateRead(context.Context, *CreateReadRequest) (*CreateReadResponse, error)
	// Streams messages received off of a read
	StartRead(*StartReadRequest, PlumberServer_StartReadServer) error
	// List all reads that have been created
	GetAllReads(context.Context, *GetAllReadsRequest) (*GetAllReadsResponse, error)
	// Stop reading data from a connection
	StopRead(context.Context, *StopReadRequest) (*StopReadResponse, error)
	// Resume reading data from an existing read
	ResumeRead(context.Context, *ResumeReadRequest) (*ResumeReadResponse, error)
	// Resume reading data from an existing read
	DeleteRead(context.Context, *DeleteReadRequest) (*DeleteReadResponse, error)
	// Write data to a connection
	Write(context.Context, *WriteRequest) (*WriteResponse, error)
	// Create a data relay from plumber server to the Batch platform
	CreateRelay(context.Context, *CreateRelayRequest) (*CreateRelayResponse, error)
	// Update a relay (such as API token) - relay will be interrupted!
	UpdateRelay(context.Context, *UpdateRelayRequest) (*UpdateRelayResponse, error)
	ResumeRelay(context.Context, *ResumeRelayRequest) (*ResumeRelayResponse, error)
	StopRelay(context.Context, *StopRelayRequest) (*StopRelayResponse, error)
	GetAllRelays(context.Context, *GetAllRelaysRequest) (*GetAllRelaysResponse, error)
	// Delete an existing relay
	DeleteRelay(context.Context, *DeleteRelayRequest) (*DeleteRelayResponse, error)
	// Begins github authorization process
	StartGithubAuth(context.Context, *StartGithubAuthRequest) (*StartGithubAuthResponse, error)
	// Starts a poll of the github authorization status
	PollGithubAuth(*PollGithubAuthRequest, PlumberServer_PollGithubAuthServer) error
	// Determines if we have authorized plumber with github
	IsGithubAuth(context.Context, *IsGithubAuthRequest) (*IsGithubAuthResponse, error)
	// Retrieve a single schema
	GetSchema(context.Context, *GetSchemaRequest) (*GetSchemaResponse, error)
	// Retrieve all schemas
	GetAllSchemas(context.Context, *GetAllSchemasRequest) (*GetAllSchemasResponse, error)
	// Import a schema from github
	ImportGithub(context.Context, *ImportGithubRequest) (*ImportGithubResponse, error)
	// Import a schema from the local file system
	ImportLocal(context.Context, *ImportLocalRequest) (*ImportLocalResponse, error)
	// Delete a schema
	DeleteSchema(context.Context, *DeleteSchemaRequest) (*DeleteSchemaResponse, error)
	GetService(context.Context, *GetServiceRequest) (*GetServiceResponse, error)
	GetAllServices(context.Context, *GetAllServicesRequest) (*GetAllServicesResponse, error)
	CreateService(context.Context, *CreateServiceRequest) (*CreateServiceResponse, error)
	UpdateService(context.Context, *UpdateServiceRequest) (*UpdateServiceResponse, error)
	DeleteService(context.Context, *DeleteServiceRequest) (*DeleteServiceResponse, error)
	GetServerOptions(context.Context, *GetServerOptionsRequest) (*GetServerOptionsResponse, error)
	// GetGithubEvents connects to github-app backend and returns a stream of events pushed from github
	GetGithubEvents(*GetGithubEventsRequest, PlumberServer_GetGithubEventsServer) error
}

PlumberServerServer is the server API for PlumberServer service.

type PlumberServer_GetGithubEventsClient added in v0.0.40 

type PlumberServer_GetGithubEventsClient interface {
	Recv() (*GithubEvent, error)
	grpc.ClientStream
}

type PlumberServer_GetGithubEventsServer added in v0.0.40 

type PlumberServer_GetGithubEventsServer interface {
	Send(*GithubEvent) error
	grpc.ServerStream
}

type PlumberServer_PollGithubAuthClient added in v0.0.25 

type PlumberServer_PollGithubAuthClient interface {
	Recv() (*PollGithubAuthResponse, error)
	grpc.ClientStream
}

type PlumberServer_PollGithubAuthServer added in v0.0.25 

type PlumberServer_PollGithubAuthServer interface {
	Send(*PollGithubAuthResponse) error
	grpc.ServerStream
}

type PlumberServer_StartReadClient 

type PlumberServer_StartReadClient interface {
	Recv() (*StartReadResponse, error)
	grpc.ClientStream
}

type PlumberServer_StartReadServer 

type PlumberServer_StartReadServer interface {
	Send(*StartReadResponse) error
	grpc.ServerStream
}

type PollGithubAuthRequest added in v0.0.25 

type PollGithubAuthRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*PollGithubAuthRequest) Descriptor added in v0.0.25 

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

func (*PollGithubAuthRequest) GetAuth added in v0.0.25 

func (m *PollGithubAuthRequest) GetAuth() *common.Auth

func (*PollGithubAuthRequest) ProtoMessage added in v0.0.25 

func (*PollGithubAuthRequest) ProtoMessage()

func (*PollGithubAuthRequest) Reset added in v0.0.25 

func (m *PollGithubAuthRequest) Reset()

func (*PollGithubAuthRequest) String added in v0.0.25 

func (m *PollGithubAuthRequest) String() string

func (*PollGithubAuthRequest) XXX_DiscardUnknown added in v0.0.25 

func (m *PollGithubAuthRequest) XXX_DiscardUnknown()

func (*PollGithubAuthRequest) XXX_Marshal added in v0.0.25 

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

func (*PollGithubAuthRequest) XXX_Merge added in v0.0.25 

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

func (*PollGithubAuthRequest) XXX_Size added in v0.0.25 

func (m *PollGithubAuthRequest) XXX_Size() int

func (*PollGithubAuthRequest) XXX_Unmarshal added in v0.0.25 

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

type PollGithubAuthResponse added in v0.0.25 

type PollGithubAuthResponse struct {
	Status               PollGithubAuthResponse_Status `protobuf:"varint,1,opt,name=status,proto3,enum=protos.PollGithubAuthResponse_Status" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*PollGithubAuthResponse) Descriptor added in v0.0.25 

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

func (*PollGithubAuthResponse) GetStatus added in v0.0.25 

func (m *PollGithubAuthResponse) GetStatus() PollGithubAuthResponse_Status

func (*PollGithubAuthResponse) ProtoMessage added in v0.0.25 

func (*PollGithubAuthResponse) ProtoMessage()

func (*PollGithubAuthResponse) Reset added in v0.0.25 

func (m *PollGithubAuthResponse) Reset()

func (*PollGithubAuthResponse) String added in v0.0.25 

func (m *PollGithubAuthResponse) String() string

func (*PollGithubAuthResponse) XXX_DiscardUnknown added in v0.0.25 

func (m *PollGithubAuthResponse) XXX_DiscardUnknown()

func (*PollGithubAuthResponse) XXX_Marshal added in v0.0.25 

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

func (*PollGithubAuthResponse) XXX_Merge added in v0.0.25 

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

func (*PollGithubAuthResponse) XXX_Size added in v0.0.25 

func (m *PollGithubAuthResponse) XXX_Size() int

func (*PollGithubAuthResponse) XXX_Unmarshal added in v0.0.25 

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

type PollGithubAuthResponse_Status added in v0.0.25 

type PollGithubAuthResponse_Status int32
const (
	PollGithubAuthResponse_PENDING PollGithubAuthResponse_Status = 0
	PollGithubAuthResponse_SUCCESS PollGithubAuthResponse_Status = 1
	PollGithubAuthResponse_FAILED  PollGithubAuthResponse_Status = 2
)

func (PollGithubAuthResponse_Status) EnumDescriptor added in v0.0.25 

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

func (PollGithubAuthResponse_Status) String added in v0.0.25 

func (x PollGithubAuthResponse_Status) String() string

type PullRequestCreated added in v0.0.40 

type PullRequestCreated struct {
	Owner                string   `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	Repo                 string   `protobuf:"bytes,2,opt,name=repo,proto3" json:"repo,omitempty"`
	Number               int32    `protobuf:"varint,3,opt,name=number,proto3" json:"number,omitempty"`
	Url                  string   `protobuf:"bytes,4,opt,name=url,proto3" json:"url,omitempty"`
	Description          string   `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Sent by github-service and received by plumber Sent by plumber, received by UI

func (*PullRequestCreated) Descriptor added in v0.0.40 

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

func (*PullRequestCreated) GetDescription added in v0.0.40 

func (m *PullRequestCreated) GetDescription() string

func (*PullRequestCreated) GetNumber added in v0.0.40 

func (m *PullRequestCreated) GetNumber() int32

func (*PullRequestCreated) GetOwner added in v0.0.40 

func (m *PullRequestCreated) GetOwner() string

func (*PullRequestCreated) GetRepo added in v0.0.40 

func (m *PullRequestCreated) GetRepo() string

func (*PullRequestCreated) GetUrl added in v0.0.40 

func (m *PullRequestCreated) GetUrl() string

func (*PullRequestCreated) ProtoMessage added in v0.0.40 

func (*PullRequestCreated) ProtoMessage()

func (*PullRequestCreated) Reset added in v0.0.40 

func (m *PullRequestCreated) Reset()

func (*PullRequestCreated) String added in v0.0.40 

func (m *PullRequestCreated) String() string

func (*PullRequestCreated) XXX_DiscardUnknown added in v0.0.40 

func (m *PullRequestCreated) XXX_DiscardUnknown()

func (*PullRequestCreated) XXX_Marshal added in v0.0.40 

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

func (*PullRequestCreated) XXX_Merge added in v0.0.40 

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

func (*PullRequestCreated) XXX_Size added in v0.0.40 

func (m *PullRequestCreated) XXX_Size() int

func (*PullRequestCreated) XXX_Unmarshal added in v0.0.40 

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

type PullRequestMerged added in v0.0.40 

type PullRequestMerged struct {
	Owner                string   `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	Repo                 string   `protobuf:"bytes,2,opt,name=repo,proto3" json:"repo,omitempty"`
	Number               int32    `protobuf:"varint,3,opt,name=number,proto3" json:"number,omitempty"`
	Url                  string   `protobuf:"bytes,4,opt,name=url,proto3" json:"url,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Sent by github-service and received by plumber Sent by plumber, received by UI

func (*PullRequestMerged) Descriptor added in v0.0.40 

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

func (*PullRequestMerged) GetNumber added in v0.0.40 

func (m *PullRequestMerged) GetNumber() int32

func (*PullRequestMerged) GetOwner added in v0.0.40 

func (m *PullRequestMerged) GetOwner() string

func (*PullRequestMerged) GetRepo added in v0.0.40 

func (m *PullRequestMerged) GetRepo() string

func (*PullRequestMerged) GetUrl added in v0.0.40 

func (m *PullRequestMerged) GetUrl() string

func (*PullRequestMerged) ProtoMessage added in v0.0.40 

func (*PullRequestMerged) ProtoMessage()

func (*PullRequestMerged) Reset added in v0.0.40 

func (m *PullRequestMerged) Reset()

func (*PullRequestMerged) String added in v0.0.40 

func (m *PullRequestMerged) String() string

func (*PullRequestMerged) XXX_DiscardUnknown added in v0.0.40 

func (m *PullRequestMerged) XXX_DiscardUnknown()

func (*PullRequestMerged) XXX_Marshal added in v0.0.40 

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

func (*PullRequestMerged) XXX_Merge added in v0.0.40 

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

func (*PullRequestMerged) XXX_Size added in v0.0.40 

func (m *PullRequestMerged) XXX_Size() int

func (*PullRequestMerged) XXX_Unmarshal added in v0.0.40 

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

type ResumeReadRequest added in v0.0.20 

type ResumeReadRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	ReadId               string       `protobuf:"bytes,1,opt,name=read_id,json=readId,proto3" json:"read_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ResumeReadRequest) Descriptor added in v0.0.20 

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

func (*ResumeReadRequest) GetAuth added in v0.0.20 

func (m *ResumeReadRequest) GetAuth() *common.Auth

func (*ResumeReadRequest) GetReadId added in v0.0.20 

func (m *ResumeReadRequest) GetReadId() string

func (*ResumeReadRequest) ProtoMessage added in v0.0.20 

func (*ResumeReadRequest) ProtoMessage()

func (*ResumeReadRequest) Reset added in v0.0.20 

func (m *ResumeReadRequest) Reset()

func (*ResumeReadRequest) String added in v0.0.20 

func (m *ResumeReadRequest) String() string

func (*ResumeReadRequest) XXX_DiscardUnknown added in v0.0.20 

func (m *ResumeReadRequest) XXX_DiscardUnknown()

func (*ResumeReadRequest) XXX_Marshal added in v0.0.20 

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

func (*ResumeReadRequest) XXX_Merge added in v0.0.20 

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

func (*ResumeReadRequest) XXX_Size added in v0.0.20 

func (m *ResumeReadRequest) XXX_Size() int

func (*ResumeReadRequest) XXX_Unmarshal added in v0.0.20 

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

type ResumeReadResponse added in v0.0.20 

type ResumeReadResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ResumeReadResponse) Descriptor added in v0.0.20 

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

func (*ResumeReadResponse) GetStatus added in v0.0.20 

func (m *ResumeReadResponse) GetStatus() *common.Status

func (*ResumeReadResponse) ProtoMessage added in v0.0.20 

func (*ResumeReadResponse) ProtoMessage()

func (*ResumeReadResponse) Reset added in v0.0.20 

func (m *ResumeReadResponse) Reset()

func (*ResumeReadResponse) String added in v0.0.20 

func (m *ResumeReadResponse) String() string

func (*ResumeReadResponse) XXX_DiscardUnknown added in v0.0.20 

func (m *ResumeReadResponse) XXX_DiscardUnknown()

func (*ResumeReadResponse) XXX_Marshal added in v0.0.20 

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

func (*ResumeReadResponse) XXX_Merge added in v0.0.20 

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

func (*ResumeReadResponse) XXX_Size added in v0.0.20 

func (m *ResumeReadResponse) XXX_Size() int

func (*ResumeReadResponse) XXX_Unmarshal added in v0.0.20 

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

type ResumeRelayRequest added in v0.0.16 

type ResumeRelayRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	RelayId              string       `protobuf:"bytes,1,opt,name=relay_id,json=relayId,proto3" json:"relay_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Resume a paused relay

func (*ResumeRelayRequest) Descriptor added in v0.0.16 

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

func (*ResumeRelayRequest) GetAuth added in v0.0.16 

func (m *ResumeRelayRequest) GetAuth() *common.Auth

func (*ResumeRelayRequest) GetRelayId added in v0.0.16 

func (m *ResumeRelayRequest) GetRelayId() string

func (*ResumeRelayRequest) ProtoMessage added in v0.0.16 

func (*ResumeRelayRequest) ProtoMessage()

func (*ResumeRelayRequest) Reset added in v0.0.16 

func (m *ResumeRelayRequest) Reset()

func (*ResumeRelayRequest) String added in v0.0.16 

func (m *ResumeRelayRequest) String() string

func (*ResumeRelayRequest) XXX_DiscardUnknown added in v0.0.16 

func (m *ResumeRelayRequest) XXX_DiscardUnknown()

func (*ResumeRelayRequest) XXX_Marshal added in v0.0.16 

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

func (*ResumeRelayRequest) XXX_Merge added in v0.0.16 

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

func (*ResumeRelayRequest) XXX_Size added in v0.0.16 

func (m *ResumeRelayRequest) XXX_Size() int

func (*ResumeRelayRequest) XXX_Unmarshal added in v0.0.16 

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

type ResumeRelayResponse added in v0.0.16 

type ResumeRelayResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ResumeRelayResponse) Descriptor added in v0.0.16 

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

func (*ResumeRelayResponse) GetStatus added in v0.0.16 

func (m *ResumeRelayResponse) GetStatus() *common.Status

func (*ResumeRelayResponse) ProtoMessage added in v0.0.16 

func (*ResumeRelayResponse) ProtoMessage()

func (*ResumeRelayResponse) Reset added in v0.0.16 

func (m *ResumeRelayResponse) Reset()

func (*ResumeRelayResponse) String added in v0.0.16 

func (m *ResumeRelayResponse) String() string

func (*ResumeRelayResponse) XXX_DiscardUnknown added in v0.0.16 

func (m *ResumeRelayResponse) XXX_DiscardUnknown()

func (*ResumeRelayResponse) XXX_Marshal added in v0.0.16 

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

func (*ResumeRelayResponse) XXX_Merge added in v0.0.16 

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

func (*ResumeRelayResponse) XXX_Size added in v0.0.16 

func (m *ResumeRelayResponse) XXX_Size() int

func (*ResumeRelayResponse) XXX_Unmarshal added in v0.0.16 

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

type Schema added in v0.0.26 

type Schema struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// This will probably have to change ~ds 09.08.21
	Type  encoding.EncodeType `protobuf:"varint,3,opt,name=type,proto3,enum=protos.encoding.EncodeType" json:"type,omitempty"`
	Files map[string]string   `` /* 151-byte string literal not displayed */
	// Protobuf only, root message name
	RootType string `protobuf:"bytes,5,opt,name=root_type,json=rootType,proto3" json:"root_type,omitempty"`
	// Protobuf only, root message descriptor
	MessageDescriptor    []byte   `protobuf:"bytes,6,opt,name=message_descriptor,json=messageDescriptor,proto3" json:"message_descriptor,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Schema) Descriptor added in v0.0.26 

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

func (*Schema) GetFiles added in v0.0.29 

func (m *Schema) GetFiles() map[string]string

func (*Schema) GetId added in v0.0.26 

func (m *Schema) GetId() string

func (*Schema) GetMessageDescriptor added in v0.0.26 

func (m *Schema) GetMessageDescriptor() []byte

func (*Schema) GetName added in v0.0.26 

func (m *Schema) GetName() string

func (*Schema) GetRootType added in v0.0.26 

func (m *Schema) GetRootType() string

func (*Schema) GetType added in v0.0.26 

func (m *Schema) GetType() encoding.EncodeType

func (*Schema) ProtoMessage added in v0.0.26 

func (*Schema) ProtoMessage()

func (*Schema) Reset added in v0.0.26 

func (m *Schema) Reset()

func (*Schema) String added in v0.0.26 

func (m *Schema) String() string

func (*Schema) XXX_DiscardUnknown added in v0.0.26 

func (m *Schema) XXX_DiscardUnknown()

func (*Schema) XXX_Marshal added in v0.0.26 

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

func (*Schema) XXX_Merge added in v0.0.26 

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

func (*Schema) XXX_Size added in v0.0.26 

func (m *Schema) XXX_Size() int

func (*Schema) XXX_Unmarshal added in v0.0.26 

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

type Service added in v0.0.27 

type Service struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	RepoUrl              string   `protobuf:"bytes,3,opt,name=repo_url,json=repoUrl,proto3" json:"repo_url,omitempty"`
	Notes                string   `protobuf:"bytes,4,opt,name=notes,proto3" json:"notes,omitempty"`
	OwnerId              string   `protobuf:"bytes,5,opt,name=owner_id,json=ownerId,proto3" json:"owner_id,omitempty"`
	UsedSchemas          []string `protobuf:"bytes,6,rep,name=used_schemas,json=usedSchemas,proto3" json:"used_schemas,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Service) Descriptor added in v0.0.27 

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

func (*Service) GetId added in v0.0.27 

func (m *Service) GetId() string

func (*Service) GetName added in v0.0.27 

func (m *Service) GetName() string

func (*Service) GetNotes added in v0.0.27 

func (m *Service) GetNotes() string

func (*Service) GetOwnerId added in v0.0.27 

func (m *Service) GetOwnerId() string

func (*Service) GetRepoUrl added in v0.0.27 

func (m *Service) GetRepoUrl() string

func (*Service) GetUsedSchemas added in v0.0.27 

func (m *Service) GetUsedSchemas() []string

func (*Service) ProtoMessage added in v0.0.27 

func (*Service) ProtoMessage()

func (*Service) Reset added in v0.0.27 

func (m *Service) Reset()

func (*Service) String added in v0.0.27 

func (m *Service) String() string

func (*Service) XXX_DiscardUnknown added in v0.0.27 

func (m *Service) XXX_DiscardUnknown()

func (*Service) XXX_Marshal added in v0.0.27 

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

func (*Service) XXX_Merge added in v0.0.27 

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

func (*Service) XXX_Size added in v0.0.27 

func (m *Service) XXX_Size() int

func (*Service) XXX_Unmarshal added in v0.0.27 

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

type StartGithubAuthRequest added in v0.0.25 

type StartGithubAuthRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*StartGithubAuthRequest) Descriptor added in v0.0.25 

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

func (*StartGithubAuthRequest) GetAuth added in v0.0.25 

func (m *StartGithubAuthRequest) GetAuth() *common.Auth

func (*StartGithubAuthRequest) ProtoMessage added in v0.0.25 

func (*StartGithubAuthRequest) ProtoMessage()

func (*StartGithubAuthRequest) Reset added in v0.0.25 

func (m *StartGithubAuthRequest) Reset()

func (*StartGithubAuthRequest) String added in v0.0.25 

func (m *StartGithubAuthRequest) String() string

func (*StartGithubAuthRequest) XXX_DiscardUnknown added in v0.0.25 

func (m *StartGithubAuthRequest) XXX_DiscardUnknown()

func (*StartGithubAuthRequest) XXX_Marshal added in v0.0.25 

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

func (*StartGithubAuthRequest) XXX_Merge added in v0.0.25 

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

func (*StartGithubAuthRequest) XXX_Size added in v0.0.25 

func (m *StartGithubAuthRequest) XXX_Size() int

func (*StartGithubAuthRequest) XXX_Unmarshal added in v0.0.25 

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

type StartGithubAuthResponse added in v0.0.25 

type StartGithubAuthResponse struct {
	// Authorization code that the user needs to enter on github's website
	Code string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	// URL that the user needs to visit to enter the code
	VerificationUrl string `protobuf:"bytes,2,opt,name=verification_url,json=verificationUrl,proto3" json:"verification_url,omitempty"`
	// Time deadline by which the user must enter the code before a new one must
	// be generated
	EnterBefore          string   `protobuf:"bytes,3,opt,name=enter_before,json=enterBefore,proto3" json:"enter_before,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StartGithubAuthResponse) Descriptor added in v0.0.25 

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

func (*StartGithubAuthResponse) GetCode added in v0.0.25 

func (m *StartGithubAuthResponse) GetCode() string

func (*StartGithubAuthResponse) GetEnterBefore added in v0.0.25 

func (m *StartGithubAuthResponse) GetEnterBefore() string

func (*StartGithubAuthResponse) GetVerificationUrl added in v0.0.25 

func (m *StartGithubAuthResponse) GetVerificationUrl() string

func (*StartGithubAuthResponse) ProtoMessage added in v0.0.25 

func (*StartGithubAuthResponse) ProtoMessage()

func (*StartGithubAuthResponse) Reset added in v0.0.25 

func (m *StartGithubAuthResponse) Reset()

func (*StartGithubAuthResponse) String added in v0.0.25 

func (m *StartGithubAuthResponse) String() string

func (*StartGithubAuthResponse) XXX_DiscardUnknown added in v0.0.25 

func (m *StartGithubAuthResponse) XXX_DiscardUnknown()

func (*StartGithubAuthResponse) XXX_Marshal added in v0.0.25 

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

func (*StartGithubAuthResponse) XXX_Merge added in v0.0.25 

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

func (*StartGithubAuthResponse) XXX_Size added in v0.0.25 

func (m *StartGithubAuthResponse) XXX_Size() int

func (*StartGithubAuthResponse) XXX_Unmarshal added in v0.0.25 

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

type StartReadRequest 

type StartReadRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	ReadId               string       `protobuf:"bytes,1,opt,name=read_id,json=readId,proto3" json:"read_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*StartReadRequest) Descriptor 

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

func (*StartReadRequest) GetAuth 

func (m *StartReadRequest) GetAuth() *common.Auth

func (*StartReadRequest) GetReadId added in v0.0.20 

func (m *StartReadRequest) GetReadId() string

func (*StartReadRequest) ProtoMessage 

func (*StartReadRequest) ProtoMessage()

func (*StartReadRequest) Reset 

func (m *StartReadRequest) Reset()

func (*StartReadRequest) String 

func (m *StartReadRequest) String() string

func (*StartReadRequest) XXX_DiscardUnknown 

func (m *StartReadRequest) XXX_DiscardUnknown()

func (*StartReadRequest) XXX_Marshal 

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

func (*StartReadRequest) XXX_Merge 

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

func (*StartReadRequest) XXX_Size 

func (m *StartReadRequest) XXX_Size() int

func (*StartReadRequest) XXX_Unmarshal 

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

type StartReadResponse 

type StartReadResponse struct {
	Records              []*records.ReadRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	Status               *common.Status        `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*StartReadResponse) Descriptor 

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

func (*StartReadResponse) GetRecords added in v0.0.33 

func (m *StartReadResponse) GetRecords() []*records.ReadRecord

func (*StartReadResponse) GetStatus 

func (m *StartReadResponse) GetStatus() *common.Status

func (*StartReadResponse) ProtoMessage 

func (*StartReadResponse) ProtoMessage()

func (*StartReadResponse) Reset 

func (m *StartReadResponse) Reset()

func (*StartReadResponse) String 

func (m *StartReadResponse) String() string

func (*StartReadResponse) XXX_DiscardUnknown 

func (m *StartReadResponse) XXX_DiscardUnknown()

func (*StartReadResponse) XXX_Marshal 

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

func (*StartReadResponse) XXX_Merge 

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

func (*StartReadResponse) XXX_Size 

func (m *StartReadResponse) XXX_Size() int

func (*StartReadResponse) XXX_Unmarshal 

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

type StopReadRequest 

type StopReadRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	ReadId               string       `protobuf:"bytes,1,opt,name=read_id,json=readId,proto3" json:"read_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*StopReadRequest) Descriptor 

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

func (*StopReadRequest) GetAuth 

func (m *StopReadRequest) GetAuth() *common.Auth

func (*StopReadRequest) GetReadId 

func (m *StopReadRequest) GetReadId() string

func (*StopReadRequest) ProtoMessage 

func (*StopReadRequest) ProtoMessage()

func (*StopReadRequest) Reset 

func (m *StopReadRequest) Reset()

func (*StopReadRequest) String 

func (m *StopReadRequest) String() string

func (*StopReadRequest) XXX_DiscardUnknown 

func (m *StopReadRequest) XXX_DiscardUnknown()

func (*StopReadRequest) XXX_Marshal 

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

func (*StopReadRequest) XXX_Merge 

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

func (*StopReadRequest) XXX_Size 

func (m *StopReadRequest) XXX_Size() int

func (*StopReadRequest) XXX_Unmarshal 

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

type StopReadResponse 

type StopReadResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*StopReadResponse) Descriptor 

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

func (*StopReadResponse) GetStatus 

func (m *StopReadResponse) GetStatus() *common.Status

func (*StopReadResponse) ProtoMessage 

func (*StopReadResponse) ProtoMessage()

func (*StopReadResponse) Reset 

func (m *StopReadResponse) Reset()

func (*StopReadResponse) String 

func (m *StopReadResponse) String() string

func (*StopReadResponse) XXX_DiscardUnknown 

func (m *StopReadResponse) XXX_DiscardUnknown()

func (*StopReadResponse) XXX_Marshal 

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

func (*StopReadResponse) XXX_Merge 

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

func (*StopReadResponse) XXX_Size 

func (m *StopReadResponse) XXX_Size() int

func (*StopReadResponse) XXX_Unmarshal 

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

type StopRelayRequest 

type StopRelayRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	RelayId              string       `protobuf:"bytes,1,opt,name=relay_id,json=relayId,proto3" json:"relay_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Temporarily stop/pause a relay

func (*StopRelayRequest) Descriptor 

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

func (*StopRelayRequest) GetAuth 

func (m *StopRelayRequest) GetAuth() *common.Auth

func (*StopRelayRequest) GetRelayId 

func (m *StopRelayRequest) GetRelayId() string

func (*StopRelayRequest) ProtoMessage 

func (*StopRelayRequest) ProtoMessage()

func (*StopRelayRequest) Reset 

func (m *StopRelayRequest) Reset()

func (*StopRelayRequest) String 

func (m *StopRelayRequest) String() string

func (*StopRelayRequest) XXX_DiscardUnknown 

func (m *StopRelayRequest) XXX_DiscardUnknown()

func (*StopRelayRequest) XXX_Marshal 

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

func (*StopRelayRequest) XXX_Merge 

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

func (*StopRelayRequest) XXX_Size 

func (m *StopRelayRequest) XXX_Size() int

func (*StopRelayRequest) XXX_Unmarshal 

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

type StopRelayResponse 

type StopRelayResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*StopRelayResponse) Descriptor 

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

func (*StopRelayResponse) GetStatus 

func (m *StopRelayResponse) GetStatus() *common.Status

func (*StopRelayResponse) ProtoMessage 

func (*StopRelayResponse) ProtoMessage()

func (*StopRelayResponse) Reset 

func (m *StopRelayResponse) Reset()

func (*StopRelayResponse) String 

func (m *StopRelayResponse) String() string

func (*StopRelayResponse) XXX_DiscardUnknown 

func (m *StopRelayResponse) XXX_DiscardUnknown()

func (*StopRelayResponse) XXX_Marshal 

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

func (*StopRelayResponse) XXX_Merge 

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

func (*StopRelayResponse) XXX_Size 

func (m *StopRelayResponse) XXX_Size() int

func (*StopRelayResponse) XXX_Unmarshal 

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

type TestConnectionRequest 

type TestConnectionRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth            `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	Options              *opts.ConnectionOptions `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*TestConnectionRequest) Descriptor 

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

func (*TestConnectionRequest) GetAuth 

func (m *TestConnectionRequest) GetAuth() *common.Auth

func (*TestConnectionRequest) GetOptions added in v0.0.49 

func (m *TestConnectionRequest) GetOptions() *opts.ConnectionOptions

func (*TestConnectionRequest) ProtoMessage 

func (*TestConnectionRequest) ProtoMessage()

func (*TestConnectionRequest) Reset 

func (m *TestConnectionRequest) Reset()

func (*TestConnectionRequest) String 

func (m *TestConnectionRequest) String() string

func (*TestConnectionRequest) XXX_DiscardUnknown 

func (m *TestConnectionRequest) XXX_DiscardUnknown()

func (*TestConnectionRequest) XXX_Marshal 

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

func (*TestConnectionRequest) XXX_Merge 

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

func (*TestConnectionRequest) XXX_Size 

func (m *TestConnectionRequest) XXX_Size() int

func (*TestConnectionRequest) XXX_Unmarshal 

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

type TestConnectionResponse 

type TestConnectionResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*TestConnectionResponse) Descriptor 

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

func (*TestConnectionResponse) GetStatus 

func (m *TestConnectionResponse) GetStatus() *common.Status

func (*TestConnectionResponse) ProtoMessage 

func (*TestConnectionResponse) ProtoMessage()

func (*TestConnectionResponse) Reset 

func (m *TestConnectionResponse) Reset()

func (*TestConnectionResponse) String 

func (m *TestConnectionResponse) String() string

func (*TestConnectionResponse) XXX_DiscardUnknown 

func (m *TestConnectionResponse) XXX_DiscardUnknown()

func (*TestConnectionResponse) XXX_Marshal 

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

func (*TestConnectionResponse) XXX_Merge 

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

func (*TestConnectionResponse) XXX_Size 

func (m *TestConnectionResponse) XXX_Size() int

func (*TestConnectionResponse) XXX_Unmarshal 

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

type UnimplementedGithubServerServer added in v0.0.41 

type UnimplementedGithubServerServer struct {
}

UnimplementedGithubServerServer can be embedded to have forward compatible implementations.

func (*UnimplementedGithubServerServer) Connect added in v0.0.41 

func (*UnimplementedGithubServerServer) Connect(req *ConnectAuthRequest, srv GithubServer_ConnectServer) error

type UnimplementedPlumberServerServer 

type UnimplementedPlumberServerServer struct {
}

UnimplementedPlumberServerServer can be embedded to have forward compatible implementations.

func (*UnimplementedPlumberServerServer) CreateConnection 

func (*UnimplementedPlumberServerServer) CreateConnection(ctx context.Context, req *CreateConnectionRequest) (*CreateConnectionResponse, error)

func (*UnimplementedPlumberServerServer) CreateRead added in v0.0.20 

func (*UnimplementedPlumberServerServer) CreateRead(ctx context.Context, req *CreateReadRequest) (*CreateReadResponse, error)

func (*UnimplementedPlumberServerServer) CreateRelay 

func (*UnimplementedPlumberServerServer) CreateRelay(ctx context.Context, req *CreateRelayRequest) (*CreateRelayResponse, error)

func (*UnimplementedPlumberServerServer) CreateService added in v0.0.27 

func (*UnimplementedPlumberServerServer) CreateService(ctx context.Context, req *CreateServiceRequest) (*CreateServiceResponse, error)

func (*UnimplementedPlumberServerServer) DeleteConnection 

func (*UnimplementedPlumberServerServer) DeleteConnection(ctx context.Context, req *DeleteConnectionRequest) (*DeleteConnectionResponse, error)

func (*UnimplementedPlumberServerServer) DeleteRead added in v0.0.20 

func (*UnimplementedPlumberServerServer) DeleteRead(ctx context.Context, req *DeleteReadRequest) (*DeleteReadResponse, error)

func (*UnimplementedPlumberServerServer) DeleteRelay 

func (*UnimplementedPlumberServerServer) DeleteRelay(ctx context.Context, req *DeleteRelayRequest) (*DeleteRelayResponse, error)

func (*UnimplementedPlumberServerServer) DeleteSchema added in v0.0.26 

func (*UnimplementedPlumberServerServer) DeleteSchema(ctx context.Context, req *DeleteSchemaRequest) (*DeleteSchemaResponse, error)

func (*UnimplementedPlumberServerServer) DeleteService added in v0.0.27 

func (*UnimplementedPlumberServerServer) DeleteService(ctx context.Context, req *DeleteServiceRequest) (*DeleteServiceResponse, error)

func (*UnimplementedPlumberServerServer) GetAllConnections 

func (*UnimplementedPlumberServerServer) GetAllConnections(ctx context.Context, req *GetAllConnectionsRequest) (*GetAllConnectionsResponse, error)

func (*UnimplementedPlumberServerServer) GetAllReads added in v0.0.18 

func (*UnimplementedPlumberServerServer) GetAllReads(ctx context.Context, req *GetAllReadsRequest) (*GetAllReadsResponse, error)

func (*UnimplementedPlumberServerServer) GetAllRelays added in v0.0.17 

func (*UnimplementedPlumberServerServer) GetAllRelays(ctx context.Context, req *GetAllRelaysRequest) (*GetAllRelaysResponse, error)

func (*UnimplementedPlumberServerServer) GetAllSchemas added in v0.0.26 

func (*UnimplementedPlumberServerServer) GetAllSchemas(ctx context.Context, req *GetAllSchemasRequest) (*GetAllSchemasResponse, error)

func (*UnimplementedPlumberServerServer) GetAllServices added in v0.0.27 

func (*UnimplementedPlumberServerServer) GetAllServices(ctx context.Context, req *GetAllServicesRequest) (*GetAllServicesResponse, error)

func (*UnimplementedPlumberServerServer) GetConnection added in v0.0.3 

func (*UnimplementedPlumberServerServer) GetConnection(ctx context.Context, req *GetConnectionRequest) (*GetConnectionResponse, error)

func (*UnimplementedPlumberServerServer) GetGithubEvents added in v0.0.40 

func (*UnimplementedPlumberServerServer) GetGithubEvents(req *GetGithubEventsRequest, srv PlumberServer_GetGithubEventsServer) error

func (*UnimplementedPlumberServerServer) GetSchema added in v0.0.26 

func (*UnimplementedPlumberServerServer) GetSchema(ctx context.Context, req *GetSchemaRequest) (*GetSchemaResponse, error)

func (*UnimplementedPlumberServerServer) GetServerOptions added in v0.0.49 

func (*UnimplementedPlumberServerServer) GetServerOptions(ctx context.Context, req *GetServerOptionsRequest) (*GetServerOptionsResponse, error)

func (*UnimplementedPlumberServerServer) GetService added in v0.0.27 

func (*UnimplementedPlumberServerServer) GetService(ctx context.Context, req *GetServiceRequest) (*GetServiceResponse, error)

func (*UnimplementedPlumberServerServer) ImportGithub added in v0.0.26 

func (*UnimplementedPlumberServerServer) ImportGithub(ctx context.Context, req *ImportGithubRequest) (*ImportGithubResponse, error)

func (*UnimplementedPlumberServerServer) ImportLocal added in v0.0.26 

func (*UnimplementedPlumberServerServer) ImportLocal(ctx context.Context, req *ImportLocalRequest) (*ImportLocalResponse, error)

func (*UnimplementedPlumberServerServer) IsGithubAuth added in v0.0.25 

func (*UnimplementedPlumberServerServer) IsGithubAuth(ctx context.Context, req *IsGithubAuthRequest) (*IsGithubAuthResponse, error)

func (*UnimplementedPlumberServerServer) PollGithubAuth added in v0.0.25 

func (*UnimplementedPlumberServerServer) PollGithubAuth(req *PollGithubAuthRequest, srv PlumberServer_PollGithubAuthServer) error

func (*UnimplementedPlumberServerServer) ResumeRead added in v0.0.20 

func (*UnimplementedPlumberServerServer) ResumeRead(ctx context.Context, req *ResumeReadRequest) (*ResumeReadResponse, error)

func (*UnimplementedPlumberServerServer) ResumeRelay added in v0.0.16 

func (*UnimplementedPlumberServerServer) ResumeRelay(ctx context.Context, req *ResumeRelayRequest) (*ResumeRelayResponse, error)

func (*UnimplementedPlumberServerServer) StartGithubAuth added in v0.0.25 

func (*UnimplementedPlumberServerServer) StartGithubAuth(ctx context.Context, req *StartGithubAuthRequest) (*StartGithubAuthResponse, error)

func (*UnimplementedPlumberServerServer) StartRead 

func (*UnimplementedPlumberServerServer) StartRead(req *StartReadRequest, srv PlumberServer_StartReadServer) error

func (*UnimplementedPlumberServerServer) StopRead 

func (*UnimplementedPlumberServerServer) StopRead(ctx context.Context, req *StopReadRequest) (*StopReadResponse, error)

func (*UnimplementedPlumberServerServer) StopRelay 

func (*UnimplementedPlumberServerServer) StopRelay(ctx context.Context, req *StopRelayRequest) (*StopRelayResponse, error)

func (*UnimplementedPlumberServerServer) TestConnection 

func (*UnimplementedPlumberServerServer) TestConnection(ctx context.Context, req *TestConnectionRequest) (*TestConnectionResponse, error)

func (*UnimplementedPlumberServerServer) UpdateConnection 

func (*UnimplementedPlumberServerServer) UpdateConnection(ctx context.Context, req *UpdateConnectionRequest) (*UpdateConnectionResponse, error)

func (*UnimplementedPlumberServerServer) UpdateRelay 

func (*UnimplementedPlumberServerServer) UpdateRelay(ctx context.Context, req *UpdateRelayRequest) (*UpdateRelayResponse, error)

func (*UnimplementedPlumberServerServer) UpdateService added in v0.0.27 

func (*UnimplementedPlumberServerServer) UpdateService(ctx context.Context, req *UpdateServiceRequest) (*UpdateServiceResponse, error)

func (*UnimplementedPlumberServerServer) Write 

func (*UnimplementedPlumberServerServer) Write(ctx context.Context, req *WriteRequest) (*WriteResponse, error)

type UpdateConnectionRequest 

type UpdateConnectionRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth            `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	ConnectionId         string                  `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	Options              *opts.ConnectionOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*UpdateConnectionRequest) Descriptor 

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

func (*UpdateConnectionRequest) GetAuth 

func (m *UpdateConnectionRequest) GetAuth() *common.Auth

func (*UpdateConnectionRequest) GetConnectionId 

func (m *UpdateConnectionRequest) GetConnectionId() string

func (*UpdateConnectionRequest) GetOptions added in v0.0.49 

func (m *UpdateConnectionRequest) GetOptions() *opts.ConnectionOptions

func (*UpdateConnectionRequest) ProtoMessage 

func (*UpdateConnectionRequest) ProtoMessage()

func (*UpdateConnectionRequest) Reset 

func (m *UpdateConnectionRequest) Reset()

func (*UpdateConnectionRequest) String 

func (m *UpdateConnectionRequest) String() string

func (*UpdateConnectionRequest) XXX_DiscardUnknown 

func (m *UpdateConnectionRequest) XXX_DiscardUnknown()

func (*UpdateConnectionRequest) XXX_Marshal 

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

func (*UpdateConnectionRequest) XXX_Merge 

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

func (*UpdateConnectionRequest) XXX_Size 

func (m *UpdateConnectionRequest) XXX_Size() int

func (*UpdateConnectionRequest) XXX_Unmarshal 

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

type UpdateConnectionResponse 

type UpdateConnectionResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*UpdateConnectionResponse) Descriptor 

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

func (*UpdateConnectionResponse) GetStatus 

func (m *UpdateConnectionResponse) GetStatus() *common.Status

func (*UpdateConnectionResponse) ProtoMessage 

func (*UpdateConnectionResponse) ProtoMessage()

func (*UpdateConnectionResponse) Reset 

func (m *UpdateConnectionResponse) Reset()

func (*UpdateConnectionResponse) String 

func (m *UpdateConnectionResponse) String() string

func (*UpdateConnectionResponse) XXX_DiscardUnknown 

func (m *UpdateConnectionResponse) XXX_DiscardUnknown()

func (*UpdateConnectionResponse) XXX_Marshal 

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

func (*UpdateConnectionResponse) XXX_Merge 

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

func (*UpdateConnectionResponse) XXX_Size 

func (m *UpdateConnectionResponse) XXX_Size() int

func (*UpdateConnectionResponse) XXX_Unmarshal 

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

type UpdateRelayRequest 

type UpdateRelayRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth       `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	RelayId              string             `protobuf:"bytes,1,opt,name=relay_id,json=relayId,proto3" json:"relay_id,omitempty"`
	Opts                 *opts.RelayOptions `protobuf:"bytes,2,opt,name=opts,proto3" json:"opts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

WARNING: Any in-progress relay will be interrupted/restarted

func (*UpdateRelayRequest) Descriptor 

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

func (*UpdateRelayRequest) GetAuth 

func (m *UpdateRelayRequest) GetAuth() *common.Auth

func (*UpdateRelayRequest) GetOpts added in v0.0.49 

func (m *UpdateRelayRequest) GetOpts() *opts.RelayOptions

func (*UpdateRelayRequest) GetRelayId 

func (m *UpdateRelayRequest) GetRelayId() string

func (*UpdateRelayRequest) ProtoMessage 

func (*UpdateRelayRequest) ProtoMessage()

func (*UpdateRelayRequest) Reset 

func (m *UpdateRelayRequest) Reset()

func (*UpdateRelayRequest) String 

func (m *UpdateRelayRequest) String() string

func (*UpdateRelayRequest) XXX_DiscardUnknown 

func (m *UpdateRelayRequest) XXX_DiscardUnknown()

func (*UpdateRelayRequest) XXX_Marshal 

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

func (*UpdateRelayRequest) XXX_Merge 

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

func (*UpdateRelayRequest) XXX_Size 

func (m *UpdateRelayRequest) XXX_Size() int

func (*UpdateRelayRequest) XXX_Unmarshal 

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

type UpdateRelayResponse 

type UpdateRelayResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*UpdateRelayResponse) Descriptor 

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

func (*UpdateRelayResponse) GetStatus 

func (m *UpdateRelayResponse) GetStatus() *common.Status

func (*UpdateRelayResponse) ProtoMessage 

func (*UpdateRelayResponse) ProtoMessage()

func (*UpdateRelayResponse) Reset 

func (m *UpdateRelayResponse) Reset()

func (*UpdateRelayResponse) String 

func (m *UpdateRelayResponse) String() string

func (*UpdateRelayResponse) XXX_DiscardUnknown 

func (m *UpdateRelayResponse) XXX_DiscardUnknown()

func (*UpdateRelayResponse) XXX_Marshal 

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

func (*UpdateRelayResponse) XXX_Merge 

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

func (*UpdateRelayResponse) XXX_Size 

func (m *UpdateRelayResponse) XXX_Size() int

func (*UpdateRelayResponse) XXX_Unmarshal 

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

type UpdateServiceRequest added in v0.0.27 

type UpdateServiceRequest struct {
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	Service              *Service     `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*UpdateServiceRequest) Descriptor added in v0.0.27 

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

func (*UpdateServiceRequest) GetAuth added in v0.0.27 

func (m *UpdateServiceRequest) GetAuth() *common.Auth

func (*UpdateServiceRequest) GetService added in v0.0.27 

func (m *UpdateServiceRequest) GetService() *Service

func (*UpdateServiceRequest) ProtoMessage added in v0.0.27 

func (*UpdateServiceRequest) ProtoMessage()

func (*UpdateServiceRequest) Reset added in v0.0.27 

func (m *UpdateServiceRequest) Reset()

func (*UpdateServiceRequest) String added in v0.0.27 

func (m *UpdateServiceRequest) String() string

func (*UpdateServiceRequest) XXX_DiscardUnknown added in v0.0.27 

func (m *UpdateServiceRequest) XXX_DiscardUnknown()

func (*UpdateServiceRequest) XXX_Marshal added in v0.0.27 

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

func (*UpdateServiceRequest) XXX_Merge added in v0.0.27 

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

func (*UpdateServiceRequest) XXX_Size added in v0.0.27 

func (m *UpdateServiceRequest) XXX_Size() int

func (*UpdateServiceRequest) XXX_Unmarshal added in v0.0.27 

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

type UpdateServiceResponse added in v0.0.27 

type UpdateServiceResponse struct {
	Service              *Service       `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*UpdateServiceResponse) Descriptor added in v0.0.27 

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

func (*UpdateServiceResponse) GetService added in v0.0.27 

func (m *UpdateServiceResponse) GetService() *Service

func (*UpdateServiceResponse) GetStatus added in v0.0.27 

func (m *UpdateServiceResponse) GetStatus() *common.Status

func (*UpdateServiceResponse) ProtoMessage added in v0.0.27 

func (*UpdateServiceResponse) ProtoMessage()

func (*UpdateServiceResponse) Reset added in v0.0.27 

func (m *UpdateServiceResponse) Reset()

func (*UpdateServiceResponse) String added in v0.0.27 

func (m *UpdateServiceResponse) String() string

func (*UpdateServiceResponse) XXX_DiscardUnknown added in v0.0.27 

func (m *UpdateServiceResponse) XXX_DiscardUnknown()

func (*UpdateServiceResponse) XXX_Marshal added in v0.0.27 

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

func (*UpdateServiceResponse) XXX_Merge added in v0.0.27 

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

func (*UpdateServiceResponse) XXX_Size added in v0.0.27 

func (m *UpdateServiceResponse) XXX_Size() int

func (*UpdateServiceResponse) XXX_Unmarshal added in v0.0.27 

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

type WriteRequest 

type WriteRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth       `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	Opts                 *opts.WriteOptions `protobuf:"bytes,1,opt,name=opts,proto3" json:"opts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*WriteRequest) Descriptor 

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

func (*WriteRequest) GetAuth 

func (m *WriteRequest) GetAuth() *common.Auth

func (*WriteRequest) GetOpts added in v0.0.49 

func (m *WriteRequest) GetOpts() *opts.WriteOptions

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset 

func (m *WriteRequest) Reset()

func (*WriteRequest) String 

func (m *WriteRequest) String() string

func (*WriteRequest) XXX_DiscardUnknown 

func (m *WriteRequest) XXX_DiscardUnknown()

func (*WriteRequest) XXX_Marshal 

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

func (*WriteRequest) XXX_Merge 

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

func (*WriteRequest) XXX_Size 

func (m *WriteRequest) XXX_Size() int

func (*WriteRequest) XXX_Unmarshal 

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

type WriteResponse 

type WriteResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*WriteResponse) Descriptor 

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

func (*WriteResponse) GetStatus 

func (m *WriteResponse) GetStatus() *common.Status

func (*WriteResponse) ProtoMessage 

func (*WriteResponse) ProtoMessage()

func (*WriteResponse) Reset 

func (m *WriteResponse) Reset()

func (*WriteResponse) String 

func (m *WriteResponse) String() string

func (*WriteResponse) XXX_DiscardUnknown 

func (m *WriteResponse) XXX_DiscardUnknown()

func (*WriteResponse) XXX_Marshal 

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

func (*WriteResponse) XXX_Merge 

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

func (*WriteResponse) XXX_Size 

func (m *WriteResponse) XXX_Size() int

func (*WriteResponse) XXX_Unmarshal 

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

Source Files

View all Source files

Directories

Path Synopsis

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.