grpcapi

package
v2.0.2 Latest Latest
Warning

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

 Go to latest Published: Mar 7, 2020 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Overview

Package grpcapi is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterRawServer 

func RegisterRawServer(s *grpc.Server, srv RawServer)

func RegisterSmartConfigServer 

func RegisterSmartConfigServer(s *grpc.Server, srv SmartConfigServer)

func RegisterWatchServiceServer 

func RegisterWatchServiceServer(s *grpc.Server, srv WatchServiceServer)

Types

type Application 

type Application struct {
	AppName              string   `protobuf:"bytes,1,opt,name=appName,proto3" json:"appName,omitempty"`
	AppVersion           string   `protobuf:"bytes,2,opt,name=appVersion,proto3" json:"appVersion,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Application) Descriptor 

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

func (*Application) GetAppName 

func (m *Application) GetAppName() string

func (*Application) GetAppVersion 

func (m *Application) GetAppVersion() string

func (*Application) ProtoMessage 

func (*Application) ProtoMessage()

func (*Application) Reset 

func (m *Application) Reset()

func (*Application) String 

func (m *Application) String() string

func (*Application) XXX_DiscardUnknown 

func (m *Application) XXX_DiscardUnknown()

func (*Application) XXX_Marshal 

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

func (*Application) XXX_Merge 

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

func (*Application) XXX_Size 

func (m *Application) XXX_Size() int

func (*Application) XXX_Unmarshal 

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

type GetConfigRequest 

type GetConfigRequest struct {
	AppName              string   `protobuf:"bytes,1,opt,name=appName,proto3" json:"appName,omitempty"`
	AppVersion           string   `protobuf:"bytes,2,opt,name=appVersion,proto3" json:"appVersion,omitempty"`
	Environment          string   `protobuf:"bytes,3,opt,name=environment,proto3" json:"environment,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetConfigRequest) Descriptor 

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

func (*GetConfigRequest) GetAppName 

func (m *GetConfigRequest) GetAppName() string

func (*GetConfigRequest) GetAppVersion 

func (m *GetConfigRequest) GetAppVersion() string

func (*GetConfigRequest) GetEnvironment 

func (m *GetConfigRequest) GetEnvironment() string

func (*GetConfigRequest) ProtoMessage 

func (*GetConfigRequest) ProtoMessage()

func (*GetConfigRequest) Reset 

func (m *GetConfigRequest) Reset()

func (*GetConfigRequest) String 

func (m *GetConfigRequest) String() string

func (*GetConfigRequest) XXX_DiscardUnknown 

func (m *GetConfigRequest) XXX_DiscardUnknown()

func (*GetConfigRequest) XXX_Marshal 

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

func (*GetConfigRequest) XXX_Merge 

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

func (*GetConfigRequest) XXX_Size 

func (m *GetConfigRequest) XXX_Size() int

func (*GetConfigRequest) XXX_Unmarshal 

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

type GetConfigResponse 

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

func (*GetConfigResponse) Descriptor 

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

func (*GetConfigResponse) GetConfigContent 

func (m *GetConfigResponse) GetConfigContent() string

func (*GetConfigResponse) ProtoMessage 

func (*GetConfigResponse) ProtoMessage()

func (*GetConfigResponse) Reset 

func (m *GetConfigResponse) Reset()

func (*GetConfigResponse) String 

func (m *GetConfigResponse) String() string

func (*GetConfigResponse) XXX_DiscardUnknown 

func (m *GetConfigResponse) XXX_DiscardUnknown()

func (*GetConfigResponse) XXX_Marshal 

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

func (*GetConfigResponse) XXX_Merge 

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

func (*GetConfigResponse) XXX_Size 

func (m *GetConfigResponse) XXX_Size() int

func (*GetConfigResponse) XXX_Unmarshal 

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

type GetFileRequest 

type GetFileRequest struct {
	AppName              string   `protobuf:"bytes,1,opt,name=appName,proto3" json:"appName,omitempty"`
	AppVersion           string   `protobuf:"bytes,2,opt,name=appVersion,proto3" json:"appVersion,omitempty"`
	FilePath             string   `protobuf:"bytes,3,opt,name=filePath,proto3" json:"filePath,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetFileRequest) Descriptor 

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

func (*GetFileRequest) GetAppName 

func (m *GetFileRequest) GetAppName() string

func (*GetFileRequest) GetAppVersion 

func (m *GetFileRequest) GetAppVersion() string

func (*GetFileRequest) GetFilePath 

func (m *GetFileRequest) GetFilePath() string

func (*GetFileRequest) ProtoMessage 

func (*GetFileRequest) ProtoMessage()

func (*GetFileRequest) Reset 

func (m *GetFileRequest) Reset()

func (*GetFileRequest) String 

func (m *GetFileRequest) String() string

func (*GetFileRequest) XXX_DiscardUnknown 

func (m *GetFileRequest) XXX_DiscardUnknown()

func (*GetFileRequest) XXX_Marshal 

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

func (*GetFileRequest) XXX_Merge 

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

func (*GetFileRequest) XXX_Size 

func (m *GetFileRequest) XXX_Size() int

func (*GetFileRequest) XXX_Unmarshal 

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

type GetFileResponse 

type GetFileResponse struct {
	FileContent          []byte   `protobuf:"bytes,1,opt,name=fileContent,proto3" json:"fileContent,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetFileResponse) Descriptor 

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

func (*GetFileResponse) GetFileContent 

func (m *GetFileResponse) GetFileContent() []byte

func (*GetFileResponse) ProtoMessage 

func (*GetFileResponse) ProtoMessage()

func (*GetFileResponse) Reset 

func (m *GetFileResponse) Reset()

func (*GetFileResponse) String 

func (m *GetFileResponse) String() string

func (*GetFileResponse) XXX_DiscardUnknown 

func (m *GetFileResponse) XXX_DiscardUnknown()

func (*GetFileResponse) XXX_Marshal 

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

func (*GetFileResponse) XXX_Merge 

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

func (*GetFileResponse) XXX_Size 

func (m *GetFileResponse) XXX_Size() int

func (*GetFileResponse) XXX_Unmarshal 

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

type MockRawClient 

type MockRawClient struct {
	// contains filtered or unexported fields
}

MockRawClient is a mock of RawClient interface

func NewMockRawClient 

func NewMockRawClient(ctrl *gomock.Controller) *MockRawClient

NewMockRawClient creates a new mock instance

func (*MockRawClient) EXPECT 

func (m *MockRawClient) EXPECT() *MockRawClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockRawClient) GetFile 

func (m *MockRawClient) GetFile(ctx context.Context, in *GetFileRequest, opts ...grpc.CallOption) (*GetFileResponse, error)

GetFile mocks base method

type MockRawClientMockRecorder 

type MockRawClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockRawClientMockRecorder is the mock recorder for MockRawClient

func (*MockRawClientMockRecorder) GetFile 

func (mr *MockRawClientMockRecorder) GetFile(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetFile indicates an expected call of GetFile

type MockRawServer 

type MockRawServer struct {
	// contains filtered or unexported fields
}

MockRawServer is a mock of RawServer interface

func NewMockRawServer 

func NewMockRawServer(ctrl *gomock.Controller) *MockRawServer

NewMockRawServer creates a new mock instance

func (*MockRawServer) EXPECT 

func (m *MockRawServer) EXPECT() *MockRawServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockRawServer) GetFile 

func (m *MockRawServer) GetFile(arg0 context.Context, arg1 *GetFileRequest) (*GetFileResponse, error)

GetFile mocks base method

type MockRawServerMockRecorder 

type MockRawServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockRawServerMockRecorder is the mock recorder for MockRawServer

func (*MockRawServerMockRecorder) GetFile 

func (mr *MockRawServerMockRecorder) GetFile(arg0, arg1 interface{}) *gomock.Call

GetFile indicates an expected call of GetFile

type MockSmartConfigClient 

type MockSmartConfigClient struct {
	// contains filtered or unexported fields
}

MockSmartConfigClient is a mock of SmartConfigClient interface

func NewMockSmartConfigClient 

func NewMockSmartConfigClient(ctrl *gomock.Controller) *MockSmartConfigClient

NewMockSmartConfigClient creates a new mock instance

func (*MockSmartConfigClient) EXPECT 

func (m *MockSmartConfigClient) EXPECT() *MockSmartConfigClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockSmartConfigClient) GetConfig 

func (m *MockSmartConfigClient) GetConfig(ctx context.Context, in *GetConfigRequest, opts ...grpc.CallOption) (*GetConfigResponse, error)

GetConfig mocks base method

type MockSmartConfigClientMockRecorder 

type MockSmartConfigClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockSmartConfigClientMockRecorder is the mock recorder for MockSmartConfigClient

func (*MockSmartConfigClientMockRecorder) GetConfig 

func (mr *MockSmartConfigClientMockRecorder) GetConfig(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetConfig indicates an expected call of GetConfig

type MockSmartConfigServer 

type MockSmartConfigServer struct {
	// contains filtered or unexported fields
}

MockSmartConfigServer is a mock of SmartConfigServer interface

func NewMockSmartConfigServer 

func NewMockSmartConfigServer(ctrl *gomock.Controller) *MockSmartConfigServer

NewMockSmartConfigServer creates a new mock instance

func (*MockSmartConfigServer) EXPECT 

func (m *MockSmartConfigServer) EXPECT() *MockSmartConfigServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockSmartConfigServer) GetConfig 

func (m *MockSmartConfigServer) GetConfig(arg0 context.Context, arg1 *GetConfigRequest) (*GetConfigResponse, error)

GetConfig mocks base method

type MockSmartConfigServerMockRecorder 

type MockSmartConfigServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockSmartConfigServerMockRecorder is the mock recorder for MockSmartConfigServer

func (*MockSmartConfigServerMockRecorder) GetConfig 

func (mr *MockSmartConfigServerMockRecorder) GetConfig(arg0, arg1 interface{}) *gomock.Call

GetConfig indicates an expected call of GetConfig

type MockWatchServiceClient 

type MockWatchServiceClient struct {
	// contains filtered or unexported fields
}

MockWatchServiceClient is a mock of WatchServiceClient interface

func NewMockWatchServiceClient 

func NewMockWatchServiceClient(ctrl *gomock.Controller) *MockWatchServiceClient

NewMockWatchServiceClient creates a new mock instance

func (*MockWatchServiceClient) EXPECT 

func (m *MockWatchServiceClient) EXPECT() *MockWatchServiceClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockWatchServiceClient) Watch 

func (m *MockWatchServiceClient) Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (WatchService_WatchClient, error)

Watch mocks base method

type MockWatchServiceClientMockRecorder 

type MockWatchServiceClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockWatchServiceClientMockRecorder is the mock recorder for MockWatchServiceClient

func (*MockWatchServiceClientMockRecorder) Watch 

func (mr *MockWatchServiceClientMockRecorder) Watch(ctx, in interface{}, opts ...interface{}) *gomock.Call

Watch indicates an expected call of Watch

type MockWatchServiceServer 

type MockWatchServiceServer struct {
	// contains filtered or unexported fields
}

MockWatchServiceServer is a mock of WatchServiceServer interface

func NewMockWatchServiceServer 

func NewMockWatchServiceServer(ctrl *gomock.Controller) *MockWatchServiceServer

NewMockWatchServiceServer creates a new mock instance

func (*MockWatchServiceServer) EXPECT 

func (m *MockWatchServiceServer) EXPECT() *MockWatchServiceServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockWatchServiceServer) Watch 

func (m *MockWatchServiceServer) Watch(arg0 *WatchRequest, arg1 WatchService_WatchServer) error

Watch mocks base method

type MockWatchServiceServerMockRecorder 

type MockWatchServiceServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockWatchServiceServerMockRecorder is the mock recorder for MockWatchServiceServer

func (*MockWatchServiceServerMockRecorder) Watch 

func (mr *MockWatchServiceServerMockRecorder) Watch(arg0, arg1 interface{}) *gomock.Call

Watch indicates an expected call of Watch

type MockWatchService_WatchClient 

type MockWatchService_WatchClient struct {
	// contains filtered or unexported fields
}

MockWatchService_WatchClient is a mock of WatchService_WatchClient interface

func NewMockWatchService_WatchClient 

func NewMockWatchService_WatchClient(ctrl *gomock.Controller) *MockWatchService_WatchClient

NewMockWatchService_WatchClient creates a new mock instance

func (*MockWatchService_WatchClient) CloseSend 

func (m *MockWatchService_WatchClient) CloseSend() error

CloseSend mocks base method

func (*MockWatchService_WatchClient) Context 

func (m *MockWatchService_WatchClient) Context() context.Context

Context mocks base method

func (*MockWatchService_WatchClient) EXPECT 

func (m *MockWatchService_WatchClient) EXPECT() *MockWatchService_WatchClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockWatchService_WatchClient) Header 

func (m *MockWatchService_WatchClient) Header() (metadata.MD, error)

Header mocks base method

func (*MockWatchService_WatchClient) Recv 

func (m *MockWatchService_WatchClient) Recv() (*WatchResponse, error)

Recv mocks base method

func (*MockWatchService_WatchClient) RecvMsg 

func (m_2 *MockWatchService_WatchClient) RecvMsg(m interface{}) error

RecvMsg mocks base method

func (*MockWatchService_WatchClient) SendMsg 

func (m_2 *MockWatchService_WatchClient) SendMsg(m interface{}) error

SendMsg mocks base method

func (*MockWatchService_WatchClient) Trailer 

func (m *MockWatchService_WatchClient) Trailer() metadata.MD

Trailer mocks base method

type MockWatchService_WatchClientMockRecorder 

type MockWatchService_WatchClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockWatchService_WatchClientMockRecorder is the mock recorder for MockWatchService_WatchClient

func (*MockWatchService_WatchClientMockRecorder) CloseSend 

func (mr *MockWatchService_WatchClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend

func (*MockWatchService_WatchClientMockRecorder) Context 

func (mr *MockWatchService_WatchClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context

func (*MockWatchService_WatchClientMockRecorder) Header 

func (mr *MockWatchService_WatchClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header

func (*MockWatchService_WatchClientMockRecorder) Recv 

func (mr *MockWatchService_WatchClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv

func (*MockWatchService_WatchClientMockRecorder) RecvMsg 

func (mr *MockWatchService_WatchClientMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg

func (*MockWatchService_WatchClientMockRecorder) SendMsg 

func (mr *MockWatchService_WatchClientMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg

func (*MockWatchService_WatchClientMockRecorder) Trailer 

func (mr *MockWatchService_WatchClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer

type MockWatchService_WatchServer 

type MockWatchService_WatchServer struct {
	// contains filtered or unexported fields
}

MockWatchService_WatchServer is a mock of WatchService_WatchServer interface

func NewMockWatchService_WatchServer 

func NewMockWatchService_WatchServer(ctrl *gomock.Controller) *MockWatchService_WatchServer

NewMockWatchService_WatchServer creates a new mock instance

func (*MockWatchService_WatchServer) Context 

func (m *MockWatchService_WatchServer) Context() context.Context

Context mocks base method

func (*MockWatchService_WatchServer) EXPECT 

func (m *MockWatchService_WatchServer) EXPECT() *MockWatchService_WatchServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockWatchService_WatchServer) RecvMsg 

func (m_2 *MockWatchService_WatchServer) RecvMsg(m interface{}) error

RecvMsg mocks base method

func (*MockWatchService_WatchServer) Send 

func (m *MockWatchService_WatchServer) Send(arg0 *WatchResponse) error

Send mocks base method

func (*MockWatchService_WatchServer) SendHeader 

func (m *MockWatchService_WatchServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method

func (*MockWatchService_WatchServer) SendMsg 

func (m_2 *MockWatchService_WatchServer) SendMsg(m interface{}) error

SendMsg mocks base method

func (*MockWatchService_WatchServer) SetHeader 

func (m *MockWatchService_WatchServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method

func (*MockWatchService_WatchServer) SetTrailer 

func (m *MockWatchService_WatchServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method

type MockWatchService_WatchServerMockRecorder 

type MockWatchService_WatchServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockWatchService_WatchServerMockRecorder is the mock recorder for MockWatchService_WatchServer

func (*MockWatchService_WatchServerMockRecorder) Context 

func (mr *MockWatchService_WatchServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context

func (*MockWatchService_WatchServerMockRecorder) RecvMsg 

func (mr *MockWatchService_WatchServerMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg

func (*MockWatchService_WatchServerMockRecorder) Send 

func (mr *MockWatchService_WatchServerMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send

func (*MockWatchService_WatchServerMockRecorder) SendHeader 

func (mr *MockWatchService_WatchServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

SendHeader indicates an expected call of SendHeader

func (*MockWatchService_WatchServerMockRecorder) SendMsg 

func (mr *MockWatchService_WatchServerMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg

func (*MockWatchService_WatchServerMockRecorder) SetHeader 

func (mr *MockWatchService_WatchServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

SetHeader indicates an expected call of SetHeader

func (*MockWatchService_WatchServerMockRecorder) SetTrailer 

func (mr *MockWatchService_WatchServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

SetTrailer indicates an expected call of SetTrailer

type RawClient 

type RawClient interface {
	GetFile(ctx context.Context, in *GetFileRequest, opts ...grpc.CallOption) (*GetFileResponse, error)
}

RawClient is the client API for Raw service.

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

func NewRawClient 

func NewRawClient(cc grpc.ClientConnInterface) RawClient

type RawServer 

type RawServer interface {
	GetFile(context.Context, *GetFileRequest) (*GetFileResponse, error)
}

RawServer is the server API for Raw service.

type Server 

type Server struct {
	// contains filtered or unexported fields
}

Server represent a GRPC server

func NewNoTLS 

func NewNoTLS(repo configrepo.Repo, address string, securityEnabled bool) (*Server, error)

NewNoTLS instantiate a new GRPC server without TLS

func NewTLS 

func NewTLS(repo configrepo.Repo, address string, securityEnabled bool, certFile, keyFile string) (*Server, error)

NewTLS instantiate a new GRPC server with TLS enabled

func (*Server) CheckToken 

func (s *Server) CheckToken(ctx context.Context, app *configrepo.ApplicationVersion) error

CheckToken checks if the request has a valid token on the GRPC metadata

func (*Server) GetConfig 

func (s *Server) GetConfig(ctx context.Context, request *GetConfigRequest) (*GetConfigResponse, error)

GetConfig returns the merged configuration based on smartconfig strategies

func (*Server) GetFile 

func (s *Server) GetFile(ctx context.Context, request *GetFileRequest) (*GetFileResponse, error)

GetFile returns a raw file on the repo

func (*Server) IsSecurityEnabled 

func (s *Server) IsSecurityEnabled() bool

IsSecurityEnabled return if the server has the security enabled

func (*Server) Start 

func (s *Server) Start() error

Start the GRPC listener

func (*Server) Stop 

func (s *Server) Stop()

Stop the GRPC listener

func (*Server) Watch 

func (s *Server) Watch(request *WatchRequest, stream WatchService_WatchServer) error

Watch manage a GRPC watch request

type SmartConfigClient 

type SmartConfigClient interface {
	GetConfig(ctx context.Context, in *GetConfigRequest, opts ...grpc.CallOption) (*GetConfigResponse, error)
}

SmartConfigClient is the client API for SmartConfig service.

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

func NewSmartConfigClient 

func NewSmartConfigClient(cc grpc.ClientConnInterface) SmartConfigClient

type SmartConfigServer 

type SmartConfigServer interface {
	GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
}

SmartConfigServer is the server API for SmartConfig service.

type UnimplementedRawServer 

type UnimplementedRawServer struct {
}

UnimplementedRawServer can be embedded to have forward compatible implementations.

func (*UnimplementedRawServer) GetFile 

func (*UnimplementedRawServer) GetFile(ctx context.Context, req *GetFileRequest) (*GetFileResponse, error)

type UnimplementedSmartConfigServer 

type UnimplementedSmartConfigServer struct {
}

UnimplementedSmartConfigServer can be embedded to have forward compatible implementations.

func (*UnimplementedSmartConfigServer) GetConfig 

func (*UnimplementedSmartConfigServer) GetConfig(ctx context.Context, req *GetConfigRequest) (*GetConfigResponse, error)

type UnimplementedWatchServiceServer 

type UnimplementedWatchServiceServer struct {
}

UnimplementedWatchServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedWatchServiceServer) Watch 

func (*UnimplementedWatchServiceServer) Watch(req *WatchRequest, srv WatchService_WatchServer) error

type WatchRequest 

type WatchRequest struct {
	WatcherName          string       `protobuf:"bytes,1,opt,name=watcherName,proto3" json:"watcherName,omitempty"`
	Application          *Application `protobuf:"bytes,2,opt,name=application,proto3" json:"application,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*WatchRequest) Descriptor 

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

func (*WatchRequest) GetApplication 

func (m *WatchRequest) GetApplication() *Application

func (*WatchRequest) GetWatcherName 

func (m *WatchRequest) GetWatcherName() string

func (*WatchRequest) ProtoMessage 

func (*WatchRequest) ProtoMessage()

func (*WatchRequest) Reset 

func (m *WatchRequest) Reset()

func (*WatchRequest) String 

func (m *WatchRequest) String() string

func (*WatchRequest) XXX_DiscardUnknown 

func (m *WatchRequest) XXX_DiscardUnknown()

func (*WatchRequest) XXX_Marshal 

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

func (*WatchRequest) XXX_Merge 

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

func (*WatchRequest) XXX_Size 

func (m *WatchRequest) XXX_Size() int

func (*WatchRequest) XXX_Unmarshal 

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

type WatchResponse 

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

func (*WatchResponse) Descriptor 

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

func (*WatchResponse) GetChanged 

func (m *WatchResponse) GetChanged() bool

func (*WatchResponse) ProtoMessage 

func (*WatchResponse) ProtoMessage()

func (*WatchResponse) Reset 

func (m *WatchResponse) Reset()

func (*WatchResponse) String 

func (m *WatchResponse) String() string

func (*WatchResponse) XXX_DiscardUnknown 

func (m *WatchResponse) XXX_DiscardUnknown()

func (*WatchResponse) XXX_Marshal 

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

func (*WatchResponse) XXX_Merge 

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

func (*WatchResponse) XXX_Size 

func (m *WatchResponse) XXX_Size() int

func (*WatchResponse) XXX_Unmarshal 

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

type WatchServiceClient 

type WatchServiceClient interface {
	Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (WatchService_WatchClient, error)
}

WatchServiceClient is the client API for WatchService service.

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

func NewWatchServiceClient 

func NewWatchServiceClient(cc grpc.ClientConnInterface) WatchServiceClient

type WatchServiceServer 

type WatchServiceServer interface {
	Watch(*WatchRequest, WatchService_WatchServer) error
}

WatchServiceServer is the server API for WatchService service.

type WatchService_WatchClient 

type WatchService_WatchClient interface {
	Recv() (*WatchResponse, error)
	grpc.ClientStream
}

type WatchService_WatchServer 

type WatchService_WatchServer interface {
	Send(*WatchResponse) error
	grpc.ServerStream
}

type Watcher 

type Watcher struct {
	// contains filtered or unexported fields
}

Watcher represent an application watcher connected through GRPC

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.