clientv1

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Sep 17, 2021 License: MIT Imports: 17 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_ras_client_v1_api_service_proto protoreflect.FileDescriptor
View Source 
var File_ras_client_v1_client_service_proto protoreflect.FileDescriptor

Functions

func DetectSupportedVersion added in v0.2.0 

func DetectSupportedVersion(err error) string

DetectSupportedVersion func helpers detect supported version in EndpointFailureAck

Types

type AdminService added in v0.3.0 

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

AdminService is the endpoint message service for RAS service.

func (*AdminService) AuthenticateCluster added in v0.3.0 

func (x *AdminService) AuthenticateCluster(ctx context.Context, req *v1.ClusterAuthenticateRequest) (*emptypb.Empty, error)

func (*AdminService) AuthenticateServer added in v0.3.0 

func (x *AdminService) AuthenticateServer(ctx context.Context, req *v1.ServerAuthenticateRequest) (*emptypb.Empty, error)

func (*AdminService) CreateClusterAdmin added in v0.3.0 

func (x *AdminService) CreateClusterAdmin(ctx context.Context, req *v1.CreateClusterAdminRequest) (*emptypb.Empty, error)

func (*AdminService) CreateServerAdmin added in v0.3.0 

func (x *AdminService) CreateServerAdmin(ctx context.Context, req *v1.CreateAgentAdminRequest) (*emptypb.Empty, error)

func (*AdminService) DeleteClusterAdmin added in v0.3.0 

func (x *AdminService) DeleteClusterAdmin(ctx context.Context, req *v1.DeleteClusterAdminRequest) (*emptypb.Empty, error)

func (*AdminService) DeleteServerAdmin added in v0.3.0 

func (x *AdminService) DeleteServerAdmin(ctx context.Context, req *v1.DeleteAgentAdminRequest) (*emptypb.Empty, error)

func (*AdminService) GetClustersAdmins added in v0.3.0 

func (x *AdminService) GetClustersAdmins(ctx context.Context, req *v1.GetClusterAdminsRequest) (*v1.GetClusterAdminsResponse, error)

func (*AdminService) GetServerAdmins added in v0.3.0 

func (x *AdminService) GetServerAdmins(ctx context.Context, req *v1.GetAgentAdminsRequest) (*v1.GetAgentAdminsResponse, error)

func (*AdminService) GetVersion added in v0.3.0 

func (x *AdminService) GetVersion(ctx context.Context, req *v1.GetAgentVersionRequest) (*v1.GetAgentVersionResponse, error)

type AdminServiceImpl added in v0.3.0 

type AdminServiceImpl interface {
	GetVersion(ctx context.Context, req *v1.GetAgentVersionRequest) (*v1.GetAgentVersionResponse, error)
	AuthenticateServer(ctx context.Context, req *v1.ServerAuthenticateRequest) (*emptypb.Empty, error)
	AuthenticateCluster(ctx context.Context, req *v1.ClusterAuthenticateRequest) (*emptypb.Empty, error)
	GetServerAdmins(ctx context.Context, req *v1.GetAgentAdminsRequest) (*v1.GetAgentAdminsResponse, error)
	GetClustersAdmins(ctx context.Context, req *v1.GetClusterAdminsRequest) (*v1.GetClusterAdminsResponse, error)
	CreateServerAdmin(ctx context.Context, req *v1.CreateAgentAdminRequest) (*emptypb.Empty, error)
	CreateClusterAdmin(ctx context.Context, req *v1.CreateClusterAdminRequest) (*emptypb.Empty, error)
	DeleteServerAdmin(ctx context.Context, req *v1.DeleteAgentAdminRequest) (*emptypb.Empty, error)
	DeleteClusterAdmin(ctx context.Context, req *v1.DeleteClusterAdminRequest) (*emptypb.Empty, error)
}

func NewAdminService added in v0.3.0 

func NewAdminService(endpointService EndpointServiceImpl) AdminServiceImpl

type AuthService 

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

AuthService is the endpoint message service for RAS service.

func (*AuthService) AuthenticateCluster 

func (x *AuthService) AuthenticateCluster(ctx context.Context, req *v1.ClusterAuthenticateRequest) (*emptypb.Empty, error)

func (*AuthService) AuthenticateInfobase 

func (x *AuthService) AuthenticateInfobase(ctx context.Context, req *v1.AuthenticateInfobaseRequest) (*emptypb.Empty, error)

func (*AuthService) AuthenticateServer added in v0.3.0 

func (x *AuthService) AuthenticateServer(ctx context.Context, req *v1.ServerAuthenticateRequest) (*emptypb.Empty, error)

type AuthServiceImpl 

type AuthServiceImpl interface {
	AuthenticateCluster(ctx context.Context, req *v1.ClusterAuthenticateRequest) (*emptypb.Empty, error)
	AuthenticateInfobase(ctx context.Context, req *v1.AuthenticateInfobaseRequest) (*emptypb.Empty, error)
	AuthenticateServer(ctx context.Context, req *v1.ServerAuthenticateRequest) (*emptypb.Empty, error)
}

func NewAuthService 

func NewAuthService(endpointService EndpointServiceImpl) AuthServiceImpl

type ClientImpl added in v0.2.0 

type ClientImpl interface {
	// Методы для блокировки соединения sync.Mutex
	// берем из sync.Locker
	sync.Locker
	// Методы для записи и чтения из соединение
	// берем из io.ReadWriter
	io.ReadWriter
}

type ClientServiceImpl 

type ClientServiceImpl interface {
	Negotiate(ctx context.Context, req *v1.NegotiateMessage) (*emptypb.Empty, error)
	Connect(ctx context.Context, req *v1.ConnectMessage) (*v1.ConnectMessageAck, error)
	Disconnect(ctx context.Context, req *v1.DisconnectMessage) (*emptypb.Empty, error)
	EndpointOpen(ctx context.Context, req *v1.EndpointOpen) (*v1.EndpointOpenAck, error)
	EndpointClose(ctx context.Context, req *v1.EndpointClose) (*emptypb.Empty, error)
	EndpointMessage(ctx context.Context, req *v1.EndpointMessage) (*v1.EndpointMessage, error)
	NewEndpoint(ctx context.Context, req *v1.EndpointOpenAck) (*v1.Endpoint, error)
}

func NewClientService 

func NewClientService(client ClientImpl) ClientServiceImpl

type ClustersService 

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

ClustersService is the endpoint message service for RAS service.

func (*ClustersService) AddWorkingServer added in v0.3.0 

func (x *ClustersService) AddWorkingServer(ctx context.Context, req *v1.AddWorkingServerRequest) (*v1.AddWorkingServerResponse, error)

func (*ClustersService) Authenticate added in v0.3.0 

func (x *ClustersService) Authenticate(ctx context.Context, req *v1.ClusterAuthenticateRequest) (*emptypb.Empty, error)

func (*ClustersService) DeleteWorkingServer added in v0.3.0 

func (x *ClustersService) DeleteWorkingServer(ctx context.Context, req *v1.DeleteWorkingServerRequest) (*emptypb.Empty, error)

func (*ClustersService) GetClusterInfo 

func (x *ClustersService) GetClusterInfo(ctx context.Context, req *v1.GetClusterInfoRequest) (*v1.GetClusterInfoResponse, error)

func (*ClustersService) GetClusters 

func (x *ClustersService) GetClusters(ctx context.Context, req *v1.GetClustersRequest) (*v1.GetClustersResponse, error)

func (*ClustersService) GetManagerInfo added in v0.3.0 

func (x *ClustersService) GetManagerInfo(ctx context.Context, req *v1.GetClusterManagerInfoRequest) (*v1.GetClusterManagerInfoResponse, error)

func (*ClustersService) GetManagers added in v0.3.0 

func (x *ClustersService) GetManagers(ctx context.Context, req *v1.GetClusterManagersRequest) (*v1.GetClusterManagersResponse, error)

func (*ClustersService) GetWorkingProcessInfo added in v0.3.0 

func (x *ClustersService) GetWorkingProcessInfo(ctx context.Context, req *v1.GetWorkingProcessInfoRequest) (*v1.GetWorkingProcessInfoResponse, error)

func (*ClustersService) GetWorkingProcesses added in v0.3.0 

func (x *ClustersService) GetWorkingProcesses(ctx context.Context, req *v1.GetWorkingProcessesRequest) (*v1.GetWorkingProcessesResponse, error)

func (*ClustersService) GetWorkingServerInfo added in v0.3.0 

func (x *ClustersService) GetWorkingServerInfo(ctx context.Context, req *v1.GetWorkingServerInfoRequest) (*v1.GetWorkingServerInfoResponse, error)

func (*ClustersService) GetWorkingServers added in v0.3.0 

func (x *ClustersService) GetWorkingServers(ctx context.Context, req *v1.GetWorkingServersRequest) (*v1.GetWorkingServersResponse, error)

func (*ClustersService) RegCluster 

func (x *ClustersService) RegCluster(ctx context.Context, req *v1.RegClusterRequest) (*v1.RegClusterResponse, error)

func (*ClustersService) UnregCluster 

func (x *ClustersService) UnregCluster(ctx context.Context, req *v1.UnregClusterRequest) (*emptypb.Empty, error)

type ClustersServiceImpl 

type ClustersServiceImpl interface {
	GetClusters(ctx context.Context, req *v1.GetClustersRequest) (*v1.GetClustersResponse, error)
	GetClusterInfo(ctx context.Context, req *v1.GetClusterInfoRequest) (*v1.GetClusterInfoResponse, error)
	RegCluster(ctx context.Context, req *v1.RegClusterRequest) (*v1.RegClusterResponse, error)
	UnregCluster(ctx context.Context, req *v1.UnregClusterRequest) (*emptypb.Empty, error)
	Authenticate(ctx context.Context, req *v1.ClusterAuthenticateRequest) (*emptypb.Empty, error)
	GetManagers(ctx context.Context, req *v1.GetClusterManagersRequest) (*v1.GetClusterManagersResponse, error)
	GetManagerInfo(ctx context.Context, req *v1.GetClusterManagerInfoRequest) (*v1.GetClusterManagerInfoResponse, error)
	GetWorkingProcesses(ctx context.Context, req *v1.GetWorkingProcessesRequest) (*v1.GetWorkingProcessesResponse, error)
	GetWorkingProcessInfo(ctx context.Context, req *v1.GetWorkingProcessInfoRequest) (*v1.GetWorkingProcessInfoResponse, error)
	GetWorkingServers(ctx context.Context, req *v1.GetWorkingServersRequest) (*v1.GetWorkingServersResponse, error)
	GetWorkingServerInfo(ctx context.Context, req *v1.GetWorkingServerInfoRequest) (*v1.GetWorkingServerInfoResponse, error)
	AddWorkingServer(ctx context.Context, req *v1.AddWorkingServerRequest) (*v1.AddWorkingServerResponse, error)
	DeleteWorkingServer(ctx context.Context, req *v1.DeleteWorkingServerRequest) (*emptypb.Empty, error)
}

func NewClustersService 

func NewClustersService(endpointService EndpointServiceImpl) ClustersServiceImpl

type ConnectionsService added in v0.3.0 

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

ConnectionsService is the endpoint message service for RAS service.

func (*ConnectionsService) DisconnectConnection added in v0.3.0 

func (x *ConnectionsService) DisconnectConnection(ctx context.Context, req *v1.DisconnectConnectionRequest) (*emptypb.Empty, error)

func (*ConnectionsService) GetConnections added in v0.3.0 

func (x *ConnectionsService) GetConnections(ctx context.Context, req *v1.GetConnectionsRequest) (*v1.GetConnectionsResponse, error)

func (*ConnectionsService) GetInfobaseSessions added in v0.3.0 

func (x *ConnectionsService) GetInfobaseSessions(ctx context.Context, req *v1.GetInfobaseConnectionsRequest) (*v1.GetInfobaseConnectionsResponse, error)

type ConnectionsServiceImpl added in v0.3.0 

type ConnectionsServiceImpl interface {
	GetConnections(ctx context.Context, req *v1.GetConnectionsRequest) (*v1.GetConnectionsResponse, error)
	GetInfobaseSessions(ctx context.Context, req *v1.GetInfobaseConnectionsRequest) (*v1.GetInfobaseConnectionsResponse, error)
	DisconnectConnection(ctx context.Context, req *v1.DisconnectConnectionRequest) (*emptypb.Empty, error)
}

func NewConnectionsService added in v0.3.0 

func NewConnectionsService(endpointService EndpointServiceImpl) ConnectionsServiceImpl

type EndpointRequest 

type EndpointRequest struct {
	Request *anypb.Any `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	Respond *anypb.Any `protobuf:"bytes,2,opt,name=respond,proto3" json:"respond,omitempty"`
	// contains filtered or unexported fields
}

func (*EndpointRequest) Descriptor deprecated 

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

Deprecated: Use EndpointRequest.ProtoReflect.Descriptor instead.

func (*EndpointRequest) GetRequest 

func (x *EndpointRequest) GetRequest() *anypb.Any

func (*EndpointRequest) GetRespond 

func (x *EndpointRequest) GetRespond() *anypb.Any

func (*EndpointRequest) ProtoMessage 

func (*EndpointRequest) ProtoMessage()

func (*EndpointRequest) ProtoReflect 

func (x *EndpointRequest) ProtoReflect() protoreflect.Message

func (*EndpointRequest) Reset 

func (x *EndpointRequest) Reset()

func (*EndpointRequest) String 

func (x *EndpointRequest) String() string

type EndpointServiceImpl 

type EndpointServiceImpl interface {
	Request(ctx context.Context, req *EndpointRequest) (*anypb.Any, error)
}

func NewEndpointService 

func NewEndpointService(clientService ClientServiceImpl, endpoint v1.EndpointImpl) EndpointServiceImpl

type InfobasesService 

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

InfobasesService is the endpoint message service for RAS service.

func (*InfobasesService) Authenticate added in v0.3.0 

func (x *InfobasesService) Authenticate(ctx context.Context, req *v1.AuthenticateInfobaseRequest) (*emptypb.Empty, error)

func (*InfobasesService) CreateInfobase added in v0.3.0 

func (x *InfobasesService) CreateInfobase(ctx context.Context, req *v1.CreateInfobaseRequest) (*v1.CreateInfobaseResponse, error)

func (*InfobasesService) DropInfobase added in v0.3.0 

func (x *InfobasesService) DropInfobase(ctx context.Context, req *v1.DropInfobaseRequest) (*emptypb.Empty, error)

func (*InfobasesService) GetInfobases added in v0.3.0 

func (x *InfobasesService) GetInfobases(ctx context.Context, req *v1.GetInfobasesRequest) (*v1.GetInfobasesResponse, error)

func (*InfobasesService) GetInfobasesSummary added in v0.3.0 

func (x *InfobasesService) GetInfobasesSummary(ctx context.Context, req *v1.GetInfobasesSummaryRequest) (*v1.GetInfobasesSummaryResponse, error)

func (*InfobasesService) UpdateInfobase added in v0.3.0 

func (x *InfobasesService) UpdateInfobase(ctx context.Context, req *v1.UpdateInfobaseRequest) (*emptypb.Empty, error)

func (*InfobasesService) UpdateInfobaseSummary added in v0.3.0 

func (x *InfobasesService) UpdateInfobaseSummary(ctx context.Context, req *v1.UpdateInfobaseSummaryRequest) (*emptypb.Empty, error)

type InfobasesServiceImpl 

type InfobasesServiceImpl interface {
	Authenticate(ctx context.Context, req *v1.AuthenticateInfobaseRequest) (*emptypb.Empty, error)
	GetInfobasesSummary(ctx context.Context, req *v1.GetInfobasesSummaryRequest) (*v1.GetInfobasesSummaryResponse, error)
	GetInfobases(ctx context.Context, req *v1.GetInfobasesRequest) (*v1.GetInfobasesResponse, error)
	CreateInfobase(ctx context.Context, req *v1.CreateInfobaseRequest) (*v1.CreateInfobaseResponse, error)
	DropInfobase(ctx context.Context, req *v1.DropInfobaseRequest) (*emptypb.Empty, error)
	UpdateInfobase(ctx context.Context, req *v1.UpdateInfobaseRequest) (*emptypb.Empty, error)
	UpdateInfobaseSummary(ctx context.Context, req *v1.UpdateInfobaseSummaryRequest) (*emptypb.Empty, error)
}

func NewInfobasesService 

func NewInfobasesService(endpointService EndpointServiceImpl) InfobasesServiceImpl

type LocksService added in v0.3.0 

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

LocksService is the endpoint message service for RAS service.

func (*LocksService) GetConnectionLocks added in v0.3.0 

func (x *LocksService) GetConnectionLocks(ctx context.Context, req *v1.GetConnectionLocksRequest) (*v1.GetConnectionLocksResponse, error)

func (*LocksService) GetInfobaseLocks added in v0.3.0 

func (x *LocksService) GetInfobaseLocks(ctx context.Context, req *v1.GetInfobaseLocksRequest) (*v1.GetInfobaseLocksResponse, error)

func (*LocksService) GetLocks added in v0.3.0 

func (x *LocksService) GetLocks(ctx context.Context, req *v1.GetLocksRequest) (*v1.GetLocksResponse, error)

func (*LocksService) GetSessionLocks added in v0.3.0 

func (x *LocksService) GetSessionLocks(ctx context.Context, req *v1.GetSessionLocksRequest) (*v1.GetSessionLocksResponse, error)

type LocksServiceImpl added in v0.3.0 

type LocksServiceImpl interface {
	GetLocks(ctx context.Context, req *v1.GetLocksRequest) (*v1.GetLocksResponse, error)
	GetInfobaseLocks(ctx context.Context, req *v1.GetInfobaseLocksRequest) (*v1.GetInfobaseLocksResponse, error)
	GetConnectionLocks(ctx context.Context, req *v1.GetConnectionLocksRequest) (*v1.GetConnectionLocksResponse, error)
	GetSessionLocks(ctx context.Context, req *v1.GetSessionLocksRequest) (*v1.GetSessionLocksResponse, error)
}

func NewLocksService added in v0.3.0 

func NewLocksService(endpointService EndpointServiceImpl) LocksServiceImpl

type SessionsService 

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

SessionsService is the endpoint message service for RAS service.

func (*SessionsService) GetInfobaseSessions added in v0.3.0 

func (x *SessionsService) GetInfobaseSessions(ctx context.Context, req *v1.GetInfobaseSessionsRequest) (*v1.GetInfobaseSessionsResponse, error)

func (*SessionsService) GetSessionInfo added in v0.3.0 

func (x *SessionsService) GetSessionInfo(ctx context.Context, req *v1.GetSessionInfoRequest) (*v1.GetSessionInfoResponse, error)

func (*SessionsService) GetSessions 

func (x *SessionsService) GetSessions(ctx context.Context, req *v1.GetSessionsRequest) (*v1.GetSessionsResponse, error)

func (*SessionsService) TerminateSession added in v0.3.0 

func (x *SessionsService) TerminateSession(ctx context.Context, req *v1.TerminateSessionRequest) (*emptypb.Empty, error)

type SessionsServiceImpl 

type SessionsServiceImpl interface {
	GetSessions(ctx context.Context, req *v1.GetSessionsRequest) (*v1.GetSessionsResponse, error)
	GetInfobaseSessions(ctx context.Context, req *v1.GetInfobaseSessionsRequest) (*v1.GetInfobaseSessionsResponse, error)
	GetSessionInfo(ctx context.Context, req *v1.GetSessionInfoRequest) (*v1.GetSessionInfoResponse, error)
	TerminateSession(ctx context.Context, req *v1.TerminateSessionRequest) (*emptypb.Empty, error)
}

func NewSessionsService 

func NewSessionsService(endpointService EndpointServiceImpl) SessionsServiceImpl

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.