proto

package
v0.16.1 Latest Latest
Warning

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

 Go to latest Published: Oct 4, 2025 License: Unlicense Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Forge_AddSymbol_FullMethodName   = "/proto.Forge/AddSymbol"
	Forge_AddBook_FullMethodName     = "/proto.Forge/AddBook"
	Forge_AddCandle_FullMethodName   = "/proto.Forge/AddCandle"
	Forge_AddTrade_FullMethodName    = "/proto.Forge/AddTrade"
	Forge_AddSchedule_FullMethodName = "/proto.Forge/AddSchedule"
	Forge_AddData_FullMethodName     = "/proto.Forge/AddData"
	Forge_Alive_FullMethodName       = "/proto.Forge/Alive"
	Forge_DaemonInfo_FullMethodName  = "/proto.Forge/DaemonInfo"
	Forge_Revive_FullMethodName      = "/proto.Forge/Revive"
	Forge_Pause_FullMethodName       = "/proto.Forge/Pause"
	Forge_Resume_FullMethodName      = "/proto.Forge/Resume"
	Forge_Restart_FullMethodName     = "/proto.Forge/Restart"
	Forge_SetConfig_FullMethodName   = "/proto.Forge/SetConfig"
	Forge_Hide_FullMethodName        = "/proto.Forge/Hide"
	Forge_Show_FullMethodName        = "/proto.Forge/Show"
	Forge_Kill_FullMethodName        = "/proto.Forge/Kill"
	Forge_Shutdown_FullMethodName    = "/proto.Forge/Shutdown"
)

Variables

View Source 
var File_service_proto protoreflect.FileDescriptor
View Source 
var Forge_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.Forge",
	HandlerType: (*ForgeServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddSymbol",
			Handler:    _Forge_AddSymbol_Handler,
		},
		{
			MethodName: "AddBook",
			Handler:    _Forge_AddBook_Handler,
		},
		{
			MethodName: "AddCandle",
			Handler:    _Forge_AddCandle_Handler,
		},
		{
			MethodName: "AddTrade",
			Handler:    _Forge_AddTrade_Handler,
		},
		{
			MethodName: "AddSchedule",
			Handler:    _Forge_AddSchedule_Handler,
		},
		{
			MethodName: "AddData",
			Handler:    _Forge_AddData_Handler,
		},
		{
			MethodName: "Alive",
			Handler:    _Forge_Alive_Handler,
		},
		{
			MethodName: "DaemonInfo",
			Handler:    _Forge_DaemonInfo_Handler,
		},
		{
			MethodName: "Revive",
			Handler:    _Forge_Revive_Handler,
		},
		{
			MethodName: "Pause",
			Handler:    _Forge_Pause_Handler,
		},
		{
			MethodName: "Resume",
			Handler:    _Forge_Resume_Handler,
		},
		{
			MethodName: "Restart",
			Handler:    _Forge_Restart_Handler,
		},
		{
			MethodName: "SetConfig",
			Handler:    _Forge_SetConfig_Handler,
		},
		{
			MethodName: "Hide",
			Handler:    _Forge_Hide_Handler,
		},
		{
			MethodName: "Show",
			Handler:    _Forge_Show_Handler,
		},
		{
			MethodName: "Kill",
			Handler:    _Forge_Kill_Handler,
		},
		{
			MethodName: "Shutdown",
			Handler:    _Forge_Shutdown_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "service.proto",
}

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

Functions

func MergeUUID 

func MergeUUID(id *ID) uuid.UUID

func RegisterForgeServer 

func RegisterForgeServer(s grpc.ServiceRegistrar, srv ForgeServer)

func SplitUUID 

func SplitUUID(id uuid.UUID) (uint64, uint64)

Types

type BinInfo 

type BinInfo struct {
	Symbol string `protobuf:"bytes,1,opt,name=symbol,proto3" json:"symbol,omitempty"`
	Path   string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*BinInfo) Descriptor deprecated 

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

Deprecated: Use BinInfo.ProtoReflect.Descriptor instead.

func (*BinInfo) GetPath 

func (x *BinInfo) GetPath() string

func (*BinInfo) GetSymbol 

func (x *BinInfo) GetSymbol() string

func (*BinInfo) ProtoMessage 

func (*BinInfo) ProtoMessage()

func (*BinInfo) ProtoReflect 

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

func (*BinInfo) Reset 

func (x *BinInfo) Reset()

func (*BinInfo) String 

func (x *BinInfo) String() string

type DaeCount 

type DaeCount struct {
	Total int64 `protobuf:"fixed64,1,opt,name=total,proto3" json:"total,omitempty"`
	// contains filtered or unexported fields
}

func (*DaeCount) Descriptor deprecated 

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

Deprecated: Use DaeCount.ProtoReflect.Descriptor instead.

func (*DaeCount) GetTotal 

func (x *DaeCount) GetTotal() int64

func (*DaeCount) ProtoMessage 

func (*DaeCount) ProtoMessage()

func (*DaeCount) ProtoReflect 

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

func (*DaeCount) Reset 

func (x *DaeCount) Reset()

func (*DaeCount) String 

func (x *DaeCount) String() string

type DaeInfo 

type DaeInfo struct {
	Id     *ID     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Status *Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Tag    string  `protobuf:"bytes,3,opt,name=tag,proto3" json:"tag,omitempty"`
	Config []byte  `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
	Report []byte  `protobuf:"bytes,5,opt,name=report,proto3" json:"report,omitempty"`
	// contains filtered or unexported fields
}

func (*DaeInfo) Descriptor deprecated 

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

Deprecated: Use DaeInfo.ProtoReflect.Descriptor instead.

func (*DaeInfo) GetConfig 

func (x *DaeInfo) GetConfig() []byte

func (*DaeInfo) GetId 

func (x *DaeInfo) GetId() *ID

func (*DaeInfo) GetReport 

func (x *DaeInfo) GetReport() []byte

func (*DaeInfo) GetStatus 

func (x *DaeInfo) GetStatus() *Status

func (*DaeInfo) GetTag 

func (x *DaeInfo) GetTag() string

func (*DaeInfo) ProtoMessage 

func (*DaeInfo) ProtoMessage()

func (*DaeInfo) ProtoReflect 

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

func (*DaeInfo) Reset 

func (x *DaeInfo) Reset()

func (*DaeInfo) String 

func (x *DaeInfo) String() string

type Filter 

type Filter struct {
	Hidden  bool    `protobuf:"varint,1,opt,name=hidden,proto3" json:"hidden,omitempty"`
	Id      *ID     `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Status  *Status `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	Tag     *string `protobuf:"bytes,4,opt,name=tag,proto3,oneof" json:"tag,omitempty"`
	Config  []byte  `protobuf:"bytes,5,opt,name=config,proto3,oneof" json:"config,omitempty"`
	Report  []byte  `protobuf:"bytes,6,opt,name=report,proto3,oneof" json:"report,omitempty"`
	Payload []byte  `protobuf:"bytes,7,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*Filter) Descriptor deprecated 

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

Deprecated: Use Filter.ProtoReflect.Descriptor instead.

func (*Filter) GetConfig 

func (x *Filter) GetConfig() []byte

func (*Filter) GetHidden 

func (x *Filter) GetHidden() bool

func (*Filter) GetId 

func (x *Filter) GetId() *ID

func (*Filter) GetPayload 

func (x *Filter) GetPayload() []byte

func (*Filter) GetReport 

func (x *Filter) GetReport() []byte

func (*Filter) GetStatus 

func (x *Filter) GetStatus() *Status

func (*Filter) GetTag 

func (x *Filter) GetTag() string

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) ProtoReflect 

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

func (*Filter) Reset 

func (x *Filter) Reset()

func (*Filter) String 

func (x *Filter) String() string

type ForgeClient 

type ForgeClient interface {
	AddSymbol(ctx context.Context, in *BinInfo, opts ...grpc.CallOption) (*Nil, error)
	AddBook(ctx context.Context, in *BinInfo, opts ...grpc.CallOption) (*Nil, error)
	AddCandle(ctx context.Context, in *BinInfo, opts ...grpc.CallOption) (*Nil, error)
	AddTrade(ctx context.Context, in *BinInfo, opts ...grpc.CallOption) (*Nil, error)
	AddSchedule(ctx context.Context, in *BinInfo, opts ...grpc.CallOption) (*Nil, error)
	AddData(ctx context.Context, in *BinInfo, opts ...grpc.CallOption) (*Nil, error)
	Alive(ctx context.Context, in *Nil, opts ...grpc.CallOption) (*DaeCount, error)
	DaemonInfo(ctx context.Context, in *Filter, opts ...grpc.CallOption) (*RepDaeInfo, error)
	Revive(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Nil, error)
	Pause(ctx context.Context, in *Filter, opts ...grpc.CallOption) (*Nil, error)
	Resume(ctx context.Context, in *Filter, opts ...grpc.CallOption) (*Nil, error)
	Restart(ctx context.Context, in *Filter, opts ...grpc.CallOption) (*Nil, error)
	SetConfig(ctx context.Context, in *Filter, opts ...grpc.CallOption) (*Nil, error)
	Hide(ctx context.Context, in *Filter, opts ...grpc.CallOption) (*Nil, error)
	Show(ctx context.Context, in *Filter, opts ...grpc.CallOption) (*Nil, error)
	Kill(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Nil, error)
	Shutdown(ctx context.Context, in *Nil, opts ...grpc.CallOption) (*Nil, error)
}

ForgeClient is the client API for Forge 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 NewForgeClient 

func NewForgeClient(cc grpc.ClientConnInterface) ForgeClient

type ForgeServer 

type ForgeServer interface {
	AddSymbol(context.Context, *BinInfo) (*Nil, error)
	AddBook(context.Context, *BinInfo) (*Nil, error)
	AddCandle(context.Context, *BinInfo) (*Nil, error)
	AddTrade(context.Context, *BinInfo) (*Nil, error)
	AddSchedule(context.Context, *BinInfo) (*Nil, error)
	AddData(context.Context, *BinInfo) (*Nil, error)
	Alive(context.Context, *Nil) (*DaeCount, error)
	DaemonInfo(context.Context, *Filter) (*RepDaeInfo, error)
	Revive(context.Context, *ID) (*Nil, error)
	Pause(context.Context, *Filter) (*Nil, error)
	Resume(context.Context, *Filter) (*Nil, error)
	Restart(context.Context, *Filter) (*Nil, error)
	SetConfig(context.Context, *Filter) (*Nil, error)
	Hide(context.Context, *Filter) (*Nil, error)
	Show(context.Context, *Filter) (*Nil, error)
	Kill(context.Context, *ID) (*Nil, error)
	Shutdown(context.Context, *Nil) (*Nil, error)
	// contains filtered or unexported methods
}

ForgeServer is the server API for Forge service. All implementations must embed UnimplementedForgeServer for forward compatibility.

type ID 

type ID struct {
	Low  uint64 `protobuf:"fixed64,1,opt,name=low,proto3" json:"low,omitempty"`
	High uint64 `protobuf:"fixed64,2,opt,name=high,proto3" json:"high,omitempty"`
	// contains filtered or unexported fields
}

func (*ID) Descriptor deprecated 

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

Deprecated: Use ID.ProtoReflect.Descriptor instead.

func (*ID) GetHigh 

func (x *ID) GetHigh() uint64

func (*ID) GetLow 

func (x *ID) GetLow() uint64

func (*ID) ProtoMessage 

func (*ID) ProtoMessage()

func (*ID) ProtoReflect 

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

func (*ID) Reset 

func (x *ID) Reset()

func (*ID) String 

func (x *ID) String() string

type Nil 

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

func (*Nil) Descriptor deprecated 

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

Deprecated: Use Nil.ProtoReflect.Descriptor instead.

func (*Nil) ProtoMessage 

func (*Nil) ProtoMessage()

func (*Nil) ProtoReflect 

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

func (*Nil) Reset 

func (x *Nil) Reset()

func (*Nil) String 

func (x *Nil) String() string

type RepDaeInfo 

type RepDaeInfo struct {
	Daemon []*DaeInfo `protobuf:"bytes,1,rep,name=daemon,proto3" json:"daemon,omitempty"`
	// contains filtered or unexported fields
}

func (*RepDaeInfo) Descriptor deprecated 

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

Deprecated: Use RepDaeInfo.ProtoReflect.Descriptor instead.

func (*RepDaeInfo) GetDaemon 

func (x *RepDaeInfo) GetDaemon() []*DaeInfo

func (*RepDaeInfo) ProtoMessage 

func (*RepDaeInfo) ProtoMessage()

func (*RepDaeInfo) ProtoReflect 

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

func (*RepDaeInfo) Reset 

func (x *RepDaeInfo) Reset()

func (*RepDaeInfo) String 

func (x *RepDaeInfo) String() string

type Status 

type Status struct {
	Code  int64 `protobuf:"fixed64,1,opt,name=code,proto3" json:"code,omitempty"`
	Since int64 `protobuf:"fixed64,2,opt,name=since,proto3" json:"since,omitempty"`
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated 

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetCode 

func (x *Status) GetCode() int64

func (*Status) GetSince 

func (x *Status) GetSince() int64

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

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

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) String 

func (x *Status) String() string

type UnimplementedForgeServer 

type UnimplementedForgeServer struct{}

UnimplementedForgeServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedForgeServer) AddBook 

func (UnimplementedForgeServer) AddBook(context.Context, *BinInfo) (*Nil, error)

func (UnimplementedForgeServer) AddCandle 

func (UnimplementedForgeServer) AddCandle(context.Context, *BinInfo) (*Nil, error)

func (UnimplementedForgeServer) AddData 

func (UnimplementedForgeServer) AddData(context.Context, *BinInfo) (*Nil, error)

func (UnimplementedForgeServer) AddSchedule 

func (UnimplementedForgeServer) AddSchedule(context.Context, *BinInfo) (*Nil, error)

func (UnimplementedForgeServer) AddSymbol 

func (UnimplementedForgeServer) AddSymbol(context.Context, *BinInfo) (*Nil, error)

func (UnimplementedForgeServer) AddTrade 

func (UnimplementedForgeServer) AddTrade(context.Context, *BinInfo) (*Nil, error)

func (UnimplementedForgeServer) Alive 

func (UnimplementedForgeServer) Alive(context.Context, *Nil) (*DaeCount, error)

func (UnimplementedForgeServer) DaemonInfo 

func (UnimplementedForgeServer) DaemonInfo(context.Context, *Filter) (*RepDaeInfo, error)

func (UnimplementedForgeServer) Hide 

func (UnimplementedForgeServer) Hide(context.Context, *Filter) (*Nil, error)

func (UnimplementedForgeServer) Kill 

func (UnimplementedForgeServer) Kill(context.Context, *ID) (*Nil, error)

func (UnimplementedForgeServer) Pause 

func (UnimplementedForgeServer) Pause(context.Context, *Filter) (*Nil, error)

func (UnimplementedForgeServer) Restart 

func (UnimplementedForgeServer) Restart(context.Context, *Filter) (*Nil, error)

func (UnimplementedForgeServer) Resume 

func (UnimplementedForgeServer) Resume(context.Context, *Filter) (*Nil, error)

func (UnimplementedForgeServer) Revive 

func (UnimplementedForgeServer) Revive(context.Context, *ID) (*Nil, error)

func (UnimplementedForgeServer) SetConfig 

func (UnimplementedForgeServer) SetConfig(context.Context, *Filter) (*Nil, error)

func (UnimplementedForgeServer) Show 

func (UnimplementedForgeServer) Show(context.Context, *Filter) (*Nil, error)

func (UnimplementedForgeServer) Shutdown 

func (UnimplementedForgeServer) Shutdown(context.Context, *Nil) (*Nil, error)

type UnsafeForgeServer 

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

UnsafeForgeServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ForgeServer 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.