proto

package
v0.0.0-...-23a443e Latest Latest
Warning

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

 Go to latest Published: Sep 17, 2024 License: AGPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Apps_GetAppLogs_FullMethodName   = "/proto.Apps/GetAppLogs"
	Apps_GetAppStatus_FullMethodName = "/proto.Apps/GetAppStatus"
)
View Source 
const (
	Instance_Init_FullMethodName     = "/proto.Instance/Init"
	Instance_GetPeers_FullMethodName = "/proto.Instance/GetPeers"
	Instance_GetLogs_FullMethodName  = "/proto.Instance/GetLogs"
)
View Source 
const (
	PeerDB_ExecSQL_FullMethodName       = "/proto.PeerDB/ExecSQL"
	PeerDB_GetAllCommits_FullMethodName = "/proto.PeerDB/GetAllCommits"
	PeerDB_GetHead_FullMethodName       = "/proto.PeerDB/GetHead"
)
View Source 
const (
	Pinger_Ping_FullMethodName = "/proto.Pinger/Ping"
)

Variables

View Source 
var Apps_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.Apps",
	HandlerType: (*AppsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetAppLogs",
			Handler:    _Apps_GetAppLogs_Handler,
		},
		{
			MethodName: "GetAppStatus",
			Handler:    _Apps_GetAppStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/p2p/proto/app.proto",
}

Apps_ServiceDesc is the grpc.ServiceDesc for Apps service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_internal_p2p_proto_app_proto protoreflect.FileDescriptor
View Source 
var File_internal_p2p_proto_instance_proto protoreflect.FileDescriptor
View Source 
var File_internal_p2p_proto_peerDB_proto protoreflect.FileDescriptor
View Source 
var File_internal_p2p_proto_pinger_proto protoreflect.FileDescriptor
View Source 
var Instance_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.Instance",
	HandlerType: (*InstanceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Init",
			Handler:    _Instance_Init_Handler,
		},
		{
			MethodName: "GetPeers",
			Handler:    _Instance_GetPeers_Handler,
		},
		{
			MethodName: "GetLogs",
			Handler:    _Instance_GetLogs_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/p2p/proto/instance.proto",
}

Instance_ServiceDesc is the grpc.ServiceDesc for Instance service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var PeerDB_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.PeerDB",
	HandlerType: (*PeerDBServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ExecSQL",
			Handler:    _PeerDB_ExecSQL_Handler,
		},
		{
			MethodName: "GetAllCommits",
			Handler:    _PeerDB_GetAllCommits_Handler,
		},
		{
			MethodName: "GetHead",
			Handler:    _PeerDB_GetHead_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/p2p/proto/peerDB.proto",
}

PeerDB_ServiceDesc is the grpc.ServiceDesc for PeerDB service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Pinger_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.Pinger",
	HandlerType: (*PingerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _Pinger_Ping_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/p2p/proto/pinger.proto",
}

Pinger_ServiceDesc is the grpc.ServiceDesc for Pinger service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterAppsServer 

func RegisterAppsServer(s grpc.ServiceRegistrar, srv AppsServer)

func RegisterInstanceServer 

func RegisterInstanceServer(s grpc.ServiceRegistrar, srv InstanceServer)

func RegisterPeerDBServer 

func RegisterPeerDBServer(s grpc.ServiceRegistrar, srv PeerDBServer)

func RegisterPingerServer 

func RegisterPingerServer(s grpc.ServiceRegistrar, srv PingerServer)

Types

type AppsClient 

type AppsClient interface {
	GetAppLogs(ctx context.Context, in *GetAppLogsRequest, opts ...grpc.CallOption) (*GetAppLogsResponse, error)
	GetAppStatus(ctx context.Context, in *GetAppStatusRequest, opts ...grpc.CallOption) (*GetAppStatusResponse, error)
}

AppsClient is the client API for Apps service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAppsClient 

func NewAppsClient(cc grpc.ClientConnInterface) AppsClient

type AppsServer 

type AppsServer interface {
	GetAppLogs(context.Context, *GetAppLogsRequest) (*GetAppLogsResponse, error)
	GetAppStatus(context.Context, *GetAppStatusRequest) (*GetAppStatusResponse, error)
}

AppsServer is the server API for Apps service. All implementations should embed UnimplementedAppsServer for forward compatibility

type Commit 

type Commit struct {
	Hash      string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	Committer string `protobuf:"bytes,2,opt,name=committer,proto3" json:"committer,omitempty"`
	Message   string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Commit) Descriptor deprecated 

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

Deprecated: Use Commit.ProtoReflect.Descriptor instead.

func (*Commit) GetCommitter 

func (x *Commit) GetCommitter() string

func (*Commit) GetHash 

func (x *Commit) GetHash() string

func (*Commit) GetMessage 

func (x *Commit) GetMessage() string

func (*Commit) ProtoMessage 

func (*Commit) ProtoMessage()

func (*Commit) ProtoReflect 

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

func (*Commit) Reset 

func (x *Commit) Reset()

func (*Commit) String 

func (x *Commit) String() string

type ExecSQLRequest 

type ExecSQLRequest struct {
	Statement string `protobuf:"bytes,1,opt,name=statement,proto3" json:"statement,omitempty"`
	Msg       string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecSQLRequest) Descriptor deprecated 

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

Deprecated: Use ExecSQLRequest.ProtoReflect.Descriptor instead.

func (*ExecSQLRequest) GetMsg 

func (x *ExecSQLRequest) GetMsg() string

func (*ExecSQLRequest) GetStatement 

func (x *ExecSQLRequest) GetStatement() string

func (*ExecSQLRequest) ProtoMessage 

func (*ExecSQLRequest) ProtoMessage()

func (*ExecSQLRequest) ProtoReflect 

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

func (*ExecSQLRequest) Reset 

func (x *ExecSQLRequest) Reset()

func (*ExecSQLRequest) String 

func (x *ExecSQLRequest) String() string

type ExecSQLResponse 

type ExecSQLResponse struct {
	Commit string `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit,omitempty"`
	Result string `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	Err    string `protobuf:"bytes,3,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecSQLResponse) Descriptor deprecated 

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

Deprecated: Use ExecSQLResponse.ProtoReflect.Descriptor instead.

func (*ExecSQLResponse) GetCommit 

func (x *ExecSQLResponse) GetCommit() string

func (*ExecSQLResponse) GetErr 

func (x *ExecSQLResponse) GetErr() string

func (*ExecSQLResponse) GetResult 

func (x *ExecSQLResponse) GetResult() string

func (*ExecSQLResponse) ProtoMessage 

func (*ExecSQLResponse) ProtoMessage()

func (*ExecSQLResponse) ProtoReflect 

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

func (*ExecSQLResponse) Reset 

func (x *ExecSQLResponse) Reset()

func (*ExecSQLResponse) String 

func (x *ExecSQLResponse) String() string

type GetAllCommitsRequest 

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

func (*GetAllCommitsRequest) Descriptor deprecated 

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

Deprecated: Use GetAllCommitsRequest.ProtoReflect.Descriptor instead.

func (*GetAllCommitsRequest) ProtoMessage 

func (*GetAllCommitsRequest) ProtoMessage()

func (*GetAllCommitsRequest) ProtoReflect 

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

func (*GetAllCommitsRequest) Reset 

func (x *GetAllCommitsRequest) Reset()

func (*GetAllCommitsRequest) String 

func (x *GetAllCommitsRequest) String() string

type GetAllCommitsResponse 

type GetAllCommitsResponse struct {
	Commits []*Commit `protobuf:"bytes,1,rep,name=commits,proto3" json:"commits,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAllCommitsResponse) Descriptor deprecated 

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

Deprecated: Use GetAllCommitsResponse.ProtoReflect.Descriptor instead.

func (*GetAllCommitsResponse) GetCommits 

func (x *GetAllCommitsResponse) GetCommits() []*Commit

func (*GetAllCommitsResponse) ProtoMessage 

func (*GetAllCommitsResponse) ProtoMessage()

func (*GetAllCommitsResponse) ProtoReflect 

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

func (*GetAllCommitsResponse) Reset 

func (x *GetAllCommitsResponse) Reset()

func (*GetAllCommitsResponse) String 

func (x *GetAllCommitsResponse) String() string

type GetAppLogsRequest 

type GetAppLogsRequest struct {
	AppName string `protobuf:"bytes,1,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAppLogsRequest) Descriptor deprecated 

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

Deprecated: Use GetAppLogsRequest.ProtoReflect.Descriptor instead.

func (*GetAppLogsRequest) GetAppName 

func (x *GetAppLogsRequest) GetAppName() string

func (*GetAppLogsRequest) ProtoMessage 

func (*GetAppLogsRequest) ProtoMessage()

func (*GetAppLogsRequest) ProtoReflect 

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

func (*GetAppLogsRequest) Reset 

func (x *GetAppLogsRequest) Reset()

func (*GetAppLogsRequest) String 

func (x *GetAppLogsRequest) String() string

type GetAppLogsResponse 

type GetAppLogsResponse struct {
	Logs string `protobuf:"bytes,1,opt,name=logs,proto3" json:"logs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAppLogsResponse) Descriptor deprecated 

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

Deprecated: Use GetAppLogsResponse.ProtoReflect.Descriptor instead.

func (*GetAppLogsResponse) GetLogs 

func (x *GetAppLogsResponse) GetLogs() string

func (*GetAppLogsResponse) ProtoMessage 

func (*GetAppLogsResponse) ProtoMessage()

func (*GetAppLogsResponse) ProtoReflect 

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

func (*GetAppLogsResponse) Reset 

func (x *GetAppLogsResponse) Reset()

func (*GetAppLogsResponse) String 

func (x *GetAppLogsResponse) String() string

type GetAppStatusRequest 

type GetAppStatusRequest struct {
	AppName string `protobuf:"bytes,1,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAppStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetAppStatusRequest.ProtoReflect.Descriptor instead.

func (*GetAppStatusRequest) GetAppName 

func (x *GetAppStatusRequest) GetAppName() string

func (*GetAppStatusRequest) ProtoMessage 

func (*GetAppStatusRequest) ProtoMessage()

func (*GetAppStatusRequest) ProtoReflect 

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

func (*GetAppStatusRequest) Reset 

func (x *GetAppStatusRequest) Reset()

func (*GetAppStatusRequest) String 

func (x *GetAppStatusRequest) String() string

type GetAppStatusResponse 

type GetAppStatusResponse struct {
	Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAppStatusResponse) Descriptor deprecated 

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

Deprecated: Use GetAppStatusResponse.ProtoReflect.Descriptor instead.

func (*GetAppStatusResponse) GetStatus 

func (x *GetAppStatusResponse) GetStatus() string

func (*GetAppStatusResponse) ProtoMessage 

func (*GetAppStatusResponse) ProtoMessage()

func (*GetAppStatusResponse) ProtoReflect 

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

func (*GetAppStatusResponse) Reset 

func (x *GetAppStatusResponse) Reset()

func (*GetAppStatusResponse) String 

func (x *GetAppStatusResponse) String() string

type GetHeadRequest 

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

func (*GetHeadRequest) Descriptor deprecated 

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

Deprecated: Use GetHeadRequest.ProtoReflect.Descriptor instead.

func (*GetHeadRequest) ProtoMessage 

func (*GetHeadRequest) ProtoMessage()

func (*GetHeadRequest) ProtoReflect 

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

func (*GetHeadRequest) Reset 

func (x *GetHeadRequest) Reset()

func (*GetHeadRequest) String 

func (x *GetHeadRequest) String() string

type GetHeadResponse 

type GetHeadResponse struct {
	Commit string `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit,omitempty"`
	// contains filtered or unexported fields
}

func (*GetHeadResponse) Descriptor deprecated 

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

Deprecated: Use GetHeadResponse.ProtoReflect.Descriptor instead.

func (*GetHeadResponse) GetCommit 

func (x *GetHeadResponse) GetCommit() string

func (*GetHeadResponse) ProtoMessage 

func (*GetHeadResponse) ProtoMessage()

func (*GetHeadResponse) ProtoReflect 

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

func (*GetHeadResponse) Reset 

func (x *GetHeadResponse) Reset()

func (*GetHeadResponse) String 

func (x *GetHeadResponse) String() string

type GetLogsRequest 

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

func (*GetLogsRequest) Descriptor deprecated 

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

Deprecated: Use GetLogsRequest.ProtoReflect.Descriptor instead.

func (*GetLogsRequest) ProtoMessage 

func (*GetLogsRequest) ProtoMessage()

func (*GetLogsRequest) ProtoReflect 

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

func (*GetLogsRequest) Reset 

func (x *GetLogsRequest) Reset()

func (*GetLogsRequest) String 

func (x *GetLogsRequest) String() string

type GetLogsResponse 

type GetLogsResponse struct {
	Logs string `protobuf:"bytes,1,opt,name=logs,proto3" json:"logs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLogsResponse) Descriptor deprecated 

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

Deprecated: Use GetLogsResponse.ProtoReflect.Descriptor instead.

func (*GetLogsResponse) GetLogs 

func (x *GetLogsResponse) GetLogs() string

func (*GetLogsResponse) ProtoMessage 

func (*GetLogsResponse) ProtoMessage()

func (*GetLogsResponse) ProtoReflect 

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

func (*GetLogsResponse) Reset 

func (x *GetLogsResponse) Reset()

func (*GetLogsResponse) String 

func (x *GetLogsResponse) String() string

type GetPeersRequest 

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

func (*GetPeersRequest) Descriptor deprecated 

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

Deprecated: Use GetPeersRequest.ProtoReflect.Descriptor instead.

func (*GetPeersRequest) ProtoMessage 

func (*GetPeersRequest) ProtoMessage()

func (*GetPeersRequest) ProtoReflect 

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

func (*GetPeersRequest) Reset 

func (x *GetPeersRequest) Reset()

func (*GetPeersRequest) String 

func (x *GetPeersRequest) String() string

type GetPeersResponse 

type GetPeersResponse struct {
	Peers map[string]string `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetPeersResponse) Descriptor deprecated 

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

Deprecated: Use GetPeersResponse.ProtoReflect.Descriptor instead.

func (*GetPeersResponse) GetPeers 

func (x *GetPeersResponse) GetPeers() map[string]string

func (*GetPeersResponse) ProtoMessage 

func (*GetPeersResponse) ProtoMessage()

func (*GetPeersResponse) ProtoReflect 

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

func (*GetPeersResponse) Reset 

func (x *GetPeersResponse) Reset()

func (*GetPeersResponse) String 

func (x *GetPeersResponse) String() string

type InitRequest 

type InitRequest struct {
	OriginDevice          string `protobuf:"bytes,1,opt,name=origin_device,json=originDevice,proto3" json:"origin_device,omitempty"`
	OriginDevicePublicKey string `` /* 128-byte string literal not displayed */
	InstanceName          string `protobuf:"bytes,4,opt,name=instance_name,json=instanceName,proto3" json:"instance_name,omitempty"`
	// contains filtered or unexported fields
}

func (*InitRequest) Descriptor deprecated 

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

Deprecated: Use InitRequest.ProtoReflect.Descriptor instead.

func (*InitRequest) GetInstanceName 

func (x *InitRequest) GetInstanceName() string

func (*InitRequest) GetOriginDevice 

func (x *InitRequest) GetOriginDevice() string

func (*InitRequest) GetOriginDevicePublicKey 

func (x *InitRequest) GetOriginDevicePublicKey() string

func (*InitRequest) ProtoMessage 

func (*InitRequest) ProtoMessage()

func (*InitRequest) ProtoReflect 

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

func (*InitRequest) Reset 

func (x *InitRequest) Reset()

func (*InitRequest) String 

func (x *InitRequest) String() string

type InitResponse 

type InitResponse struct {
	Architecture string `protobuf:"bytes,1,opt,name=architecture,proto3" json:"architecture,omitempty"`
	// contains filtered or unexported fields
}

func (*InitResponse) Descriptor deprecated 

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

Deprecated: Use InitResponse.ProtoReflect.Descriptor instead.

func (*InitResponse) GetArchitecture 

func (x *InitResponse) GetArchitecture() string

func (*InitResponse) ProtoMessage 

func (*InitResponse) ProtoMessage()

func (*InitResponse) ProtoReflect 

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

func (*InitResponse) Reset 

func (x *InitResponse) Reset()

func (*InitResponse) String 

func (x *InitResponse) String() string

type InstanceClient 

type InstanceClient interface {
	Init(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*InitResponse, error)
	GetPeers(ctx context.Context, in *GetPeersRequest, opts ...grpc.CallOption) (*GetPeersResponse, error)
	GetLogs(ctx context.Context, in *GetLogsRequest, opts ...grpc.CallOption) (*GetLogsResponse, error)
}

InstanceClient is the client API for Instance service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewInstanceClient 

func NewInstanceClient(cc grpc.ClientConnInterface) InstanceClient

type InstanceServer 

type InstanceServer interface {
	Init(context.Context, *InitRequest) (*InitResponse, error)
	GetPeers(context.Context, *GetPeersRequest) (*GetPeersResponse, error)
	GetLogs(context.Context, *GetLogsRequest) (*GetLogsResponse, error)
}

InstanceServer is the server API for Instance service. All implementations should embed UnimplementedInstanceServer for forward compatibility

type PeerDBClient 

type PeerDBClient interface {
	ExecSQL(ctx context.Context, in *ExecSQLRequest, opts ...grpc.CallOption) (*ExecSQLResponse, error)
	GetAllCommits(ctx context.Context, in *GetAllCommitsRequest, opts ...grpc.CallOption) (*GetAllCommitsResponse, error)
	GetHead(ctx context.Context, in *GetHeadRequest, opts ...grpc.CallOption) (*GetHeadResponse, error)
}

PeerDBClient is the client API for PeerDB service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewPeerDBClient 

func NewPeerDBClient(cc grpc.ClientConnInterface) PeerDBClient

type PeerDBServer 

type PeerDBServer interface {
	ExecSQL(context.Context, *ExecSQLRequest) (*ExecSQLResponse, error)
	GetAllCommits(context.Context, *GetAllCommitsRequest) (*GetAllCommitsResponse, error)
	GetHead(context.Context, *GetHeadRequest) (*GetHeadResponse, error)
}

PeerDBServer is the server API for PeerDB service. All implementations should embed UnimplementedPeerDBServer for forward compatibility

type PingRequest 

type PingRequest struct {
	Ping string `protobuf:"bytes,1,opt,name=ping,proto3" json:"ping,omitempty"`
	// contains filtered or unexported fields
}

func (*PingRequest) Descriptor deprecated 

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) GetPing 

func (x *PingRequest) GetPing() string

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect 

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

func (*PingRequest) Reset 

func (x *PingRequest) Reset()

func (*PingRequest) String 

func (x *PingRequest) String() string

type PingResponse 

type PingResponse struct {
	Pong string `protobuf:"bytes,1,opt,name=pong,proto3" json:"pong,omitempty"`
	// contains filtered or unexported fields
}

func (*PingResponse) Descriptor deprecated 

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

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) GetPong 

func (x *PingResponse) GetPong() string

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect 

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

func (*PingResponse) Reset 

func (x *PingResponse) Reset()

func (*PingResponse) String 

func (x *PingResponse) String() string

type PingerClient 

type PingerClient interface {
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
}

PingerClient is the client API for Pinger service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewPingerClient 

func NewPingerClient(cc grpc.ClientConnInterface) PingerClient

type PingerServer 

type PingerServer interface {
	Ping(context.Context, *PingRequest) (*PingResponse, error)
}

PingerServer is the server API for Pinger service. All implementations should embed UnimplementedPingerServer for forward compatibility

type UnimplementedAppsServer 

type UnimplementedAppsServer struct {
}

UnimplementedAppsServer should be embedded to have forward compatible implementations.

func (UnimplementedAppsServer) GetAppLogs 

func (UnimplementedAppsServer) GetAppLogs(context.Context, *GetAppLogsRequest) (*GetAppLogsResponse, error)

func (UnimplementedAppsServer) GetAppStatus 

func (UnimplementedAppsServer) GetAppStatus(context.Context, *GetAppStatusRequest) (*GetAppStatusResponse, error)

type UnimplementedInstanceServer 

type UnimplementedInstanceServer struct {
}

UnimplementedInstanceServer should be embedded to have forward compatible implementations.

func (UnimplementedInstanceServer) GetLogs 

func (UnimplementedInstanceServer) GetLogs(context.Context, *GetLogsRequest) (*GetLogsResponse, error)

func (UnimplementedInstanceServer) GetPeers 

func (UnimplementedInstanceServer) GetPeers(context.Context, *GetPeersRequest) (*GetPeersResponse, error)

func (UnimplementedInstanceServer) Init 

func (UnimplementedInstanceServer) Init(context.Context, *InitRequest) (*InitResponse, error)

type UnimplementedPeerDBServer 

type UnimplementedPeerDBServer struct {
}

UnimplementedPeerDBServer should be embedded to have forward compatible implementations.

func (UnimplementedPeerDBServer) ExecSQL 

func (UnimplementedPeerDBServer) ExecSQL(context.Context, *ExecSQLRequest) (*ExecSQLResponse, error)

func (UnimplementedPeerDBServer) GetAllCommits 

func (UnimplementedPeerDBServer) GetAllCommits(context.Context, *GetAllCommitsRequest) (*GetAllCommitsResponse, error)

func (UnimplementedPeerDBServer) GetHead 

func (UnimplementedPeerDBServer) GetHead(context.Context, *GetHeadRequest) (*GetHeadResponse, error)

type UnimplementedPingerServer 

type UnimplementedPingerServer struct {
}

UnimplementedPingerServer should be embedded to have forward compatible implementations.

func (UnimplementedPingerServer) Ping 

func (UnimplementedPingerServer) Ping(context.Context, *PingRequest) (*PingResponse, error)

type UnsafeAppsServer 

type UnsafeAppsServer interface {
	// contains filtered or unexported methods
}

UnsafeAppsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AppsServer will result in compilation errors.

type UnsafeInstanceServer 

type UnsafeInstanceServer interface {
	// contains filtered or unexported methods
}

UnsafeInstanceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to InstanceServer will result in compilation errors.

type UnsafePeerDBServer 

type UnsafePeerDBServer interface {
	// contains filtered or unexported methods
}

UnsafePeerDBServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PeerDBServer will result in compilation errors.

type UnsafePingerServer 

type UnsafePingerServer interface {
	// contains filtered or unexported methods
}

UnsafePingerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PingerServer will result in compilation errors.

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.